Uses of Class
org.apache.qpid.protonj2.codec.DecodeException
Package
Description
-
Uses of DecodeException in org.apache.qpid.protonj2.codec
Modifier and TypeMethodDescriptionDecoderState.decodeUTF8
(ProtonBuffer buffer, int length) Given a set of UTF-8 encoded bytes decode and return the String that represents that UTF-8 value.StreamDecoderState.decodeUTF8
(InputStream stream, int length) Given a stream that will provide UTF-8 encoded bytes, decode and return the String that represents that UTF-8 value.TypeDecoder
<?> Decoder.peekNextTypeDecoder
(ProtonBuffer buffer, DecoderState state) Peeks ahead in the givenProtonBuffer
instance and returns aTypeDecoder
that can read the next encoded AMQP type from the buffer's bytes.StreamDecoder.peekNextTypeDecoder
(InputStream stream, StreamDecoderState state) Peeks ahead in the givenInputStream
instance and returns aTypeDecoder
that can read the next encoded AMQP type from the stream's bytes.V[]
StreamTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Reads a series of this type that have been encoded into the body of an Array type.V[]
TypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Reads a series of this type that have been encoded into the body of an Array type.Decoder.readBinary
(ProtonBuffer buffer, DecoderState state) Reads an encodedBinary
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readBinary
(InputStream stream, StreamDecoderState state) Reads an encodedBinary
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readBinaryAsBuffer
(ProtonBuffer buffer, DecoderState state) Reads an encodedBinary
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readBinaryAsBuffer
(InputStream stream, StreamDecoderState state) Reads an encodedBinary
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readBoolean
(ProtonBuffer buffer, DecoderState state) Reads an encodedBoolean
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.boolean
Decoder.readBoolean
(ProtonBuffer buffer, DecoderState state, boolean defaultValue) Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state) Reads an encodedBoolean
value from the givenInputStream
assuming that the next value in the byte stream is that type.boolean
StreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state, boolean defaultValue) Reads an encodedByte
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readByte
(ProtonBuffer buffer, DecoderState state) Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.byte
Decoder.readByte
(ProtonBuffer buffer, DecoderState state, byte defaultValue) Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readByte
(InputStream stream, StreamDecoderState state) Reads an encodedByte
value from the givenInputStream
assuming that the next value in the byte stream is that type.byte
StreamDecoder.readByte
(InputStream stream, StreamDecoderState state, byte defaultValue) Reads an encodedByte
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readCharacter
(ProtonBuffer buffer, DecoderState state) Reads an encodedCharacter
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.char
Decoder.readCharacter
(ProtonBuffer buffer, DecoderState state, char defaultValue) Reads an encodedCharacter
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state) Reads an encodedCharacter
value from the givenInputStream
assuming that the next value in the byte stream is that type.char
StreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state, char defaultValue) Reads an encodedCharacter
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readDecimal128
(ProtonBuffer buffer, DecoderState state) Reads an encodedDecimal128
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readDecimal128
(InputStream stream, StreamDecoderState state) Reads an encodedDecimal128
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readDecimal32
(ProtonBuffer buffer, DecoderState state) Reads an encodedDecimal32
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readDecimal32
(InputStream stream, StreamDecoderState state) Reads an encodedDecimal32
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readDecimal64
(ProtonBuffer buffer, DecoderState state) Reads an encodedDecimal64
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readDecimal64
(InputStream stream, StreamDecoderState state) Reads an encodedDecimal64
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readDeliveryTag
(ProtonBuffer buffer, DecoderState state) This method expects to read aBinary
encoded type from the provided buffer and constructs aDeliveryTag
type that wraps the bytes encoded.StreamDecoder.readDeliveryTag
(InputStream stream, StreamDecoderState state) This method expects to read aBinary
encoded type from the provided stream and constructs aDeliveryTag
type that wraps the bytes encoded.Decoder.readDouble
(ProtonBuffer buffer, DecoderState state) Reads an encodedDouble
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.double
Decoder.readDouble
(ProtonBuffer buffer, DecoderState state, double defaultValue) Reads an encodedDouble
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readDouble
(InputStream stream, StreamDecoderState state) Reads an encodedDouble
value from the givenInputStream
assuming that the next value in the byte stream is that type.double
StreamDecoder.readDouble
(InputStream stream, StreamDecoderState state, double defaultValue) Reads an encodedDouble
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readFloat
(ProtonBuffer buffer, DecoderState state) Reads an encodedFloat
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.float
Decoder.readFloat
(ProtonBuffer buffer, DecoderState state, float defaultValue) Reads an encodedFloat
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readFloat
(InputStream stream, StreamDecoderState state) Reads an encodedFloat
value from the givenInputStream
assuming that the next value in the byte stream is that type.float
StreamDecoder.readFloat
(InputStream stream, StreamDecoderState state, float defaultValue) Reads an encodedFloat
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readInteger
(ProtonBuffer buffer, DecoderState state) Reads an encodedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder.readInteger
(ProtonBuffer buffer, DecoderState state, int defaultValue) Reads an encodedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readInteger
(InputStream stream, StreamDecoderState state) Reads an encodedInteger
value from the givenInputStream
assuming that the next value in the byte stream is that type.int
StreamDecoder.readInteger
(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedInteger
value from the givenInputStream
assuming that the next value in the byte stream is that type.<V> List
<V> Decoder.readList
(ProtonBuffer buffer, DecoderState state) Reads an encodedList
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.<V> List
<V> StreamDecoder.readList
(InputStream stream, StreamDecoderState state) Reads an encodedList
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readLong
(ProtonBuffer buffer, DecoderState state) Reads an encodedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder.readLong
(ProtonBuffer buffer, DecoderState state, long defaultValue) Reads an encodedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readLong
(InputStream stream, StreamDecoderState state) Reads an encodedLong
value from the givenInputStream
assuming that the next value in the byte stream is that type.long
StreamDecoder.readLong
(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedLong
value from the givenInputStream
assuming that the next value in the byte stream is that type.<K,
V> Map <K, V> Decoder.readMap
(ProtonBuffer buffer, DecoderState state) Reads an encodedMap
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.<K,
V> Map <K, V> StreamDecoder.readMap
(InputStream stream, StreamDecoderState state) Reads an encodedMap
value from the givenInputStream
assuming that the next value in the byte stream is that type.<T> T[]
Decoder.readMultiple
(ProtonBuffer buffer, DecoderState state, Class<T> clazz) Reads one or more encoded values from the givenProtonBuffer
an return it as an array ofObject
instances which the caller must then interpret.<T> T[]
StreamDecoder.readMultiple
(InputStream stream, StreamDecoderState state, Class<T> clazz) Reads one or more encoded values from the givenInputStream
an return it as an array ofObject
instances which the caller must then interpret.TypeDecoder
<?> Decoder.readNextTypeDecoder
(ProtonBuffer buffer, DecoderState state) Reads from the givenProtonBuffer
instance and returns aTypeDecoder
that can read the next encoded AMQP type from the buffer's bytes.StreamDecoder.readNextTypeDecoder
(InputStream stream, StreamDecoderState state) Reads from the givenInputStream
instance and returns aStreamTypeDecoder
that can read the next encoded AMQP type from the stream's bytes.Decoder.readObject
(ProtonBuffer buffer, DecoderState state) Reads an encoded value from the givenProtonBuffer
an return it as anObject
which the caller must then interpret.<T> T
Decoder.readObject
(ProtonBuffer buffer, DecoderState state, Class<T> clazz) Reads an encoded value from the givenProtonBuffer
an return it as anObject
which the caller must then interpret.StreamDecoder.readObject
(InputStream stream, StreamDecoderState state) Reads an encoded value from the givenInputStream
an return it as anObject
which the caller must then interpret.<T> T
StreamDecoder.readObject
(InputStream stream, StreamDecoderState state, Class<T> clazz) Reads an encoded value from the givenInputStream
an return it as anObject
which the caller must then interpret.Decoder.readShort
(ProtonBuffer buffer, DecoderState state) Reads an encodedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.short
Decoder.readShort
(ProtonBuffer buffer, DecoderState state, short defaultValue) Reads an encodedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readShort
(InputStream stream, StreamDecoderState state) Reads an encodedShort
value from the givenInputStream
assuming that the next value in the byte stream is that type.short
StreamDecoder.readShort
(InputStream stream, StreamDecoderState state, short defaultValue) Reads an encodedShort
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readString
(ProtonBuffer buffer, DecoderState state) Reads an encodedString
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readString
(InputStream stream, StreamDecoderState state) Reads an encodedString
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readSymbol
(ProtonBuffer buffer, DecoderState state) Reads an encodedSymbol
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.Decoder.readSymbol
(ProtonBuffer buffer, DecoderState state, String defaultValue) Reads an encodedString
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state) Reads an encodedSymbol
value from the givenInputStream
assuming that the next value in the byte stream is that type.StreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state, String defaultValue) Reads an encodedString
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readTimestamp
(ProtonBuffer buffer, DecoderState state) Reads an encoded AMQP time stamp value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder.readTimestamp
(ProtonBuffer buffer, DecoderState state, long defaultValue) Reads an encoded AMQP time stamp value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state) Reads an encoded AMQP time stamp value from the givenInputStream
assuming that the next value in the byte stream is that type.long
StreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encoded AMQP time stamp value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readUnsignedByte
(ProtonBuffer buffer, DecoderState state) Reads an encodedUnsignedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.byte
Decoder.readUnsignedByte
(ProtonBuffer buffer, DecoderState state, byte defaultValue) Reads an encodedUnsignedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedByte
value from the givenInputStream
assuming that the next value in the byte stream is that type.byte
StreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state, byte defaultValue) Reads an encodedUnsignedByte
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state) Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state, int defaultValue) Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state, long defaultValue) Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedInteger
value from the givenInputStream
assuming that the next value in the byte stream is that type.int
StreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedUnsignedInteger
value from the givenInputStream
assuming that the next value in the byte stream is that type.long
StreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedUnsignedInteger
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readUnsignedLong
(ProtonBuffer buffer, DecoderState state) Reads an encodedUnsignedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder.readUnsignedLong
(ProtonBuffer buffer, DecoderState state, long defaultValue) Reads an encodedUnsignedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedLong
value from the givenInputStream
assuming that the next value in the byte stream is that type.long
StreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedUnsignedLong
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state) Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state, int defaultValue) Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.short
Decoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state, short defaultValue) Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedShort
value from the givenInputStream
assuming that the next value in the byte stream is that type.int
StreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedUnsignedShort
value from the givenInputStream
assuming that the next value in the byte stream is that type.short
StreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state, short defaultValue) Reads an encodedUnsignedShort
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decoder.readUUID
(ProtonBuffer buffer, DecoderState state) Reads an encodedUUID
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.StreamDecoder.readUUID
(InputStream stream, StreamDecoderState state) Reads an encodedUUID
value from the givenInputStream
assuming that the next value in the byte stream is that type.StreamTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Reads the next type from the given buffer and returns it.TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Reads the next type from the given buffer and returns it.void
StreamTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) Skips over the bytes that compose the type this descriptor decodes.void
TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) Skips over the bytes that compose the type this descriptor decodes. -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders
Modifier and TypeMethodDescriptionprotected static void
AbstractDescribedTypeDecoder.checkIsExpectedType
(Class<?> expected, StreamTypeDecoder<?> actual) protected static void
AbstractDescribedTypeDecoder.checkIsExpectedType
(Class<?> expected, TypeDecoder<?> actual) protected static <E> E
AbstractDescribedTypeDecoder.checkIsExpectedTypeAndCast
(Class<?> expected, StreamTypeDecoder<?> actual) protected static <E> E
AbstractDescribedTypeDecoder.checkIsExpectedTypeAndCast
(Class<?> expected, TypeDecoder<?> actual) ProtonDecoderState.decodeUTF8
(ProtonBuffer buffer, int length) ProtonStreamDecoderState.decodeUTF8
(InputStream stream, int length) TypeDecoder
<?> ProtonDecoder.peekNextTypeDecoder
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.peekNextTypeDecoder
(InputStream stream, StreamDecoderState state) V[]
AbstractPrimitiveTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) V[]
AbstractPrimitiveTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) final DescribedType[]
UnknownDescribedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) final DescribedType[]
UnknownDescribedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) ProtonDecoder.readBinary
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readBinary
(InputStream stream, StreamDecoderState state) ProtonDecoder.readBinaryAsBuffer
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readBinaryAsBuffer
(InputStream stream, StreamDecoderState state) ProtonDecoder.readBoolean
(ProtonBuffer buffer, DecoderState state) boolean
ProtonDecoder.readBoolean
(ProtonBuffer buffer, DecoderState state, boolean defaultValue) ProtonStreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state) boolean
ProtonStreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state, boolean defaultValue) ProtonDecoder.readByte
(ProtonBuffer buffer, DecoderState state) byte
ProtonDecoder.readByte
(ProtonBuffer buffer, DecoderState state, byte defaultValue) ProtonStreamDecoder.readByte
(InputStream stream, StreamDecoderState state) byte
ProtonStreamDecoder.readByte
(InputStream stream, StreamDecoderState state, byte defaultValue) static byte
ProtonStreamUtils.readByte
(InputStream stream) Reads a single byte from the givenInputStream
and thrown aDecodeException
if theInputStream
indicates an EOF condition was encountered.static byte[]
ProtonStreamUtils.readBytes
(InputStream stream, int length) Reads the given number of bytes from the providedInputStream
into an array and return that to the caller.ProtonDecoder.readCharacter
(ProtonBuffer buffer, DecoderState state) char
ProtonDecoder.readCharacter
(ProtonBuffer buffer, DecoderState state, char defaultValue) ProtonStreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state) char
ProtonStreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state, char defaultValue) ProtonDecoder.readDecimal128
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readDecimal128
(InputStream stream, StreamDecoderState state) ProtonDecoder.readDecimal32
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readDecimal32
(InputStream stream, StreamDecoderState state) ProtonDecoder.readDecimal64
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readDecimal64
(InputStream stream, StreamDecoderState state) ProtonDecoder.readDeliveryTag
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readDeliveryTag
(InputStream stream, StreamDecoderState state) ProtonDecoder.readDouble
(ProtonBuffer buffer, DecoderState state) double
ProtonDecoder.readDouble
(ProtonBuffer buffer, DecoderState state, double defaultValue) ProtonStreamDecoder.readDouble
(InputStream stream, StreamDecoderState state) double
ProtonStreamDecoder.readDouble
(InputStream stream, StreamDecoderState state, double defaultValue) static byte
ProtonStreamUtils.readEncodingCode
(InputStream stream) Reads a single byte from the givenInputStream
and thrown aDecodeException
if theInputStream
indicates an EOF condition was encountered.ProtonDecoder.readFloat
(ProtonBuffer buffer, DecoderState state) float
ProtonDecoder.readFloat
(ProtonBuffer buffer, DecoderState state, float defaultValue) ProtonStreamDecoder.readFloat
(InputStream stream, StreamDecoderState state) float
ProtonStreamDecoder.readFloat
(InputStream stream, StreamDecoderState state, float defaultValue) ProtonDecoder.readInteger
(ProtonBuffer buffer, DecoderState state) int
ProtonDecoder.readInteger
(ProtonBuffer buffer, DecoderState state, int defaultValue) ProtonStreamDecoder.readInteger
(InputStream stream, StreamDecoderState state) int
ProtonStreamDecoder.readInteger
(InputStream stream, StreamDecoderState state, int defaultValue) <V> List
<V> ProtonDecoder.readList
(ProtonBuffer buffer, DecoderState state) <V> List
<V> ProtonStreamDecoder.readList
(InputStream stream, StreamDecoderState state) ProtonDecoder.readLong
(ProtonBuffer buffer, DecoderState state) long
ProtonDecoder.readLong
(ProtonBuffer buffer, DecoderState state, long defaultValue) ProtonStreamDecoder.readLong
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readLong
(InputStream stream, StreamDecoderState state, long defaultValue) <K,
V> Map <K, V> ProtonDecoder.readMap
(ProtonBuffer buffer, DecoderState state) <K,
V> Map <K, V> ProtonStreamDecoder.readMap
(InputStream stream, StreamDecoderState state) <T> T[]
ProtonDecoder.readMultiple
(ProtonBuffer buffer, DecoderState state, Class<T> clazz) <T> T[]
ProtonStreamDecoder.readMultiple
(InputStream stream, StreamDecoderState state, Class<T> clazz) TypeDecoder
<?> ProtonDecoder.readNextTypeDecoder
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readNextTypeDecoder
(InputStream stream, StreamDecoderState state) ProtonDecoder.readObject
(ProtonBuffer buffer, DecoderState state) <T> T
ProtonDecoder.readObject
(ProtonBuffer buffer, DecoderState state, Class<T> clazz) ProtonStreamDecoder.readObject
(InputStream stream, StreamDecoderState state) <T> T
ProtonStreamDecoder.readObject
(InputStream stream, StreamDecoderState state, Class<T> clazz) ProtonDecoder.readShort
(ProtonBuffer buffer, DecoderState state) short
ProtonDecoder.readShort
(ProtonBuffer buffer, DecoderState state, short defaultValue) ProtonStreamDecoder.readShort
(InputStream stream, StreamDecoderState state) short
ProtonStreamDecoder.readShort
(InputStream stream, StreamDecoderState state, short defaultValue) ProtonDecoder.readString
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readString
(InputStream stream, StreamDecoderState state) ProtonDecoder.readSymbol
(ProtonBuffer buffer, DecoderState state) ProtonDecoder.readSymbol
(ProtonBuffer buffer, DecoderState state, String defaultValue) ProtonStreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state, String defaultValue) ProtonDecoder.readTimestamp
(ProtonBuffer buffer, DecoderState state) long
ProtonDecoder.readTimestamp
(ProtonBuffer buffer, DecoderState state, long defaultValue) ProtonStreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state, long defaultValue) ProtonDecoder.readUnsignedByte
(ProtonBuffer buffer, DecoderState state) byte
ProtonDecoder.readUnsignedByte
(ProtonBuffer buffer, DecoderState state, byte defaultValue) ProtonStreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state) byte
ProtonStreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state, byte defaultValue) ProtonDecoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state) int
ProtonDecoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state, int defaultValue) long
ProtonDecoder.readUnsignedInteger
(ProtonBuffer buffer, DecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state) int
ProtonStreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state, int defaultValue) long
ProtonStreamDecoder.readUnsignedInteger
(InputStream stream, StreamDecoderState state, long defaultValue) ProtonDecoder.readUnsignedLong
(ProtonBuffer buffer, DecoderState state) long
ProtonDecoder.readUnsignedLong
(ProtonBuffer buffer, DecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state, long defaultValue) ProtonDecoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state) int
ProtonDecoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state, int defaultValue) short
ProtonDecoder.readUnsignedShort
(ProtonBuffer buffer, DecoderState state, short defaultValue) ProtonStreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state) int
ProtonStreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state, int defaultValue) short
ProtonStreamDecoder.readUnsignedShort
(InputStream stream, StreamDecoderState state, short defaultValue) ProtonDecoder.readUUID
(ProtonBuffer buffer, DecoderState state) ProtonStreamDecoder.readUUID
(InputStream stream, StreamDecoderState state) final DescribedType
UnknownDescribedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) final DescribedType
UnknownDescribedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) static InputStream
ProtonStreamUtils.reset
(InputStream stream) Attempts to reset the providedInputStream
to a previously marked point.protected <KeyType> void
AbstractDescribedMapTypeDecoder.scanMapEntries
(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) protected <KeyType> void
AbstractDescribedMapTypeDecoder.scanMapEntries
(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) final void
AbstractDescribedListTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) final void
AbstractDescribedListTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) final void
AbstractDescribedMapTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) final void
AbstractDescribedMapTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) final void
UnknownDescribedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) final void
UnknownDescribedTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders.messaging
Modifier and TypeMethodDescriptionAccepted[]
AcceptedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Accepted[]
AcceptedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) AmqpSequenceTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AmqpSequenceTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) AmqpValueTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AmqpValueTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) ApplicationPropertiesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) ApplicationPropertiesTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Data[]
DataTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Data[]
DataTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DeleteOnCloseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnCloseTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DeleteOnNoLinksOrMessagesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoLinksOrMessagesTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DeleteOnNoLinksTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoLinksTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DeleteOnNoMessagesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoMessagesTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DeliveryAnnotationsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeliveryAnnotationsTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Footer[]
FooterTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Footer[]
FooterTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Header[]
HeaderTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Header[]
HeaderTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) MessageAnnotationsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) MessageAnnotationsTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Modified[]
ModifiedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Modified[]
ModifiedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) PropertiesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) PropertiesTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Received[]
ReceivedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Received[]
ReceivedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Rejected[]
RejectedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Rejected[]
RejectedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Released[]
ReleasedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Released[]
ReleasedTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Source[]
SourceTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Source[]
SourceTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Target[]
TargetTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Target[]
TargetTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) AcceptedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AcceptedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AmqpSequenceTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AmqpSequence
<?> AmqpSequenceTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AmqpValueTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AmqpValue
<?> AmqpValueTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ApplicationPropertiesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ApplicationPropertiesTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DataTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DataTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeleteOnCloseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnCloseTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeleteOnNoLinksOrMessagesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoLinksOrMessagesTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeleteOnNoLinksTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoLinksTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeleteOnNoMessagesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoMessagesTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeliveryAnnotationsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeliveryAnnotationsTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) FooterTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FooterTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) HeaderTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) HeaderTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) MessageAnnotationsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) MessageAnnotationsTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ModifiedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ModifiedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) PropertiesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) PropertiesTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ReceivedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ReceivedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) RejectedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) RejectedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ReleasedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ReleasedTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) SourceTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SourceTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) TargetTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TargetTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) void
DeliveryAnnotationsTypeDecoder.scanAnnotations
(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedDeliveryAnnotations
map looking for keys that match with the providedScanningContext
.void
DeliveryAnnotationsTypeDecoder.scanAnnotations
(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedApplicationProperties
map looking for keys that match with the providedScanningContext
.void
FooterTypeDecoder.scanAnnotations
(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedFooter
map looking for keys that match with the providedScanningContext
.void
FooterTypeDecoder.scanAnnotations
(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedFooter
map looking for keys that match with the providedScanningContext
.void
MessageAnnotationsTypeDecoder.scanAnnotations
(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedMessageAnnotations
map looking for keys that match with the providedScanningContext
.void
MessageAnnotationsTypeDecoder.scanAnnotations
(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedMessageAnnotations
map looking for keys that match with the providedScanningContext
.void
ApplicationPropertiesTypeDecoder.scanProperties
(InputStream stream, StreamDecoderState state, StreamScanningContext<String> context, BiConsumer<String, Object> matchConsumer) Scans through the encodedApplicationProperties
map looking for keys that match with the providedScanningContext
.void
ApplicationPropertiesTypeDecoder.scanProperties
(ProtonBuffer buffer, DecoderState state, ScanningContext<String> context, BiConsumer<String, Object> matchConsumer) Scans through the encodedApplicationProperties
map looking for keys that match with the providedScanningContext
.void
AmqpSequenceTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AmqpSequenceTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AmqpValueTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AmqpValueTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
DataTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DataTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders.primitives
Modifier and TypeMethodDescriptionint
Array32TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
Array8TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
List0TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List0TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
List32TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List32TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
List8TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List8TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
ListTypeDecoder.readCount
(InputStream stream, StreamDecoderState state) Reads the number of elements contained in the encoded list from the providedInputStream
.int
ListTypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) Reads the number of elements contained in the encoded list from the providedProtonBuffer
.int
Map32TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
Map32TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
Map8TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
Map8TypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) int
MapTypeDecoder.readCount
(InputStream stream, StreamDecoderState state) Reads the count of entries in the encoded Map.int
MapTypeDecoder.readCount
(ProtonBuffer buffer, DecoderState state) Reads the count of entries in the encoded Map.boolean
BooleanFalseTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) boolean
BooleanFalseTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) boolean
BooleanTrueTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) boolean
BooleanTrueTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) boolean
BooleanTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.boolean
BooleanTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.byte
ByteTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.byte
ByteTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.char
CharacterTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.char
CharacterTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.double
DoubleTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.double
DoubleTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.float
FloatTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.float
FloatTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.int
Integer32TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.int
Integer32TypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.int
Integer8TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.int
Integer8TypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.long
Long8TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) long
Long8TypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) long
LongTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.long
LongTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.short
ShortTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.short
ShortTypeDecoder.readPrimitiveValue
(ProtonBuffer buffer, DecoderState state) Reads the primitive value from the givenProtonBuffer
and returns it.int
Array32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Array8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Binary32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Binary8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Binary8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
List0TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List0TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
List32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
List8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Map32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Map32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Map8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Map8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
String32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
String32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
String8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
String8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Symbol32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Symbol32TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) int
Symbol8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Symbol8TypeDecoder.readSize
(ProtonBuffer buffer, DecoderState state) AbstractSymbolTypeDecoder.readString
(InputStream stream, StreamDecoderState state) Reads a String view of an encoded Symbol value from the given buffer.AbstractSymbolTypeDecoder.readString
(ProtonBuffer buffer, DecoderState state) Reads a String view of an encoded Symbol value from the given buffer.AbstractArrayTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractArrayTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AbstractBinaryTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractBinaryTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AbstractListTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractListTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AbstractMapTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractMapTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AbstractStringTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractStringTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) AbstractSymbolTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractSymbolTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) BooleanFalseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanFalseTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) BooleanTrueTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanTrueTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) BooleanTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ByteTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ByteTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) CharacterTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) CharacterTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Decimal128TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal128TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Decimal32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal32TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Decimal64TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal64TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DoubleTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DoubleTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) FloatTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FloatTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Integer32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Integer32TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Integer8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Integer8TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) List0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) List0TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) Long8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Long8TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) LongTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) LongTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) NullTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) NullTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ShortTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ShortTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) TimestampTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TimestampTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedByteTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedByteTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedInteger0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger0TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedInteger32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger32TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedInteger8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger8TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedLong0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong0TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedLong64TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong64TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedLong8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong8TypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UnsignedShortTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedShortTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) UUIDTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UUIDTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) byte[]
AbstractBinaryTypeDecoder.readValueAsArray
(InputStream stream, StreamDecoderState state) Read and decode an AMQPBinary
into a byte array instance and return it.byte[]
AbstractBinaryTypeDecoder.readValueAsArray
(ProtonBuffer buffer, DecoderState state) Read and decode an AMQPBinary
into a byte array instance and return it.AbstractBinaryTypeDecoder.readValueAsBuffer
(InputStream stream, StreamDecoderState state) Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.AbstractBinaryTypeDecoder.readValueAsBuffer
(ProtonBuffer buffer, DecoderState state) Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.<KeyType> void
AbstractMapTypeDecoder.scanKeys
(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) <KeyType> void
AbstractMapTypeDecoder.scanKeys
(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) <KeyType> void
MapTypeDecoder.scanKeys
(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) Scan the encodedMap
keys matching on predetermined key value encodings to quickly find mappings that are of interest and then only decoding the value portion of the matched key / value pair.<KeyType> void
MapTypeDecoder.scanKeys
(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) Scan the encodedMap
keys matching on predetermined key value encodings to quickly find mappings that are of interest and then only decoding the value portion of the matched key / value pair.void
AbstractArrayTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractArrayTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AbstractBinaryTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractBinaryTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AbstractListTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractListTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AbstractMapTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractMapTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AbstractStringTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractStringTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
AbstractSymbolTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractSymbolTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
BooleanFalseTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanFalseTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
BooleanTrueTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanTrueTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
BooleanTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
ByteTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ByteTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
CharacterTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
CharacterTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Decimal128TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal128TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Decimal32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal32TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Decimal64TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal64TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
DoubleTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DoubleTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
FloatTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
FloatTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Integer32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Integer32TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Integer8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Integer8TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
List0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
List0TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
Long8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Long8TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
LongTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
LongTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
NullTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
NullTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
ShortTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ShortTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
TimestampTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
TimestampTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedByteTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedByteTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedInteger0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger0TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedInteger32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger32TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedInteger8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger8TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedLong0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong0TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedLong64TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong64TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedLong8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong8TypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UnsignedShortTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedShortTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) void
UUIDTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UUIDTypeDecoder.skipValue
(ProtonBuffer buffer, DecoderState state) -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders.security
Modifier and TypeMethodDescriptionSaslChallengeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslChallengeTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) SaslInit[]
SaslInitTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslInit[]
SaslInitTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) SaslMechanismsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslMechanismsTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) SaslOutcomeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslOutcomeTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) SaslResponseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslResponseTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) SaslChallengeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslChallengeTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) SaslInitTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslInitTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) SaslMechanismsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslMechanismsTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) SaslOutcomeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslOutcomeTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) SaslResponseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslResponseTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders.transactions
Modifier and TypeMethodDescriptionCoordinatorTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) CoordinatorTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Declared[]
DeclaredTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Declared[]
DeclaredTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Declare[]
DeclareTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Declare[]
DeclareTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DischargeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DischargeTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) TransactionStateTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) TransactionStateTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) CoordinatorTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) CoordinatorTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeclaredTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeclaredTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DeclareTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeclareTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DischargeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DischargeTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) TransactionStateTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TransactionStateTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) -
Uses of DecodeException in org.apache.qpid.protonj2.codec.decoders.transport
Modifier and TypeMethodDescriptionAttach[]
AttachTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Attach[]
AttachTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Begin[]
BeginTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Begin[]
BeginTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Close[]
CloseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Close[]
CloseTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Detach[]
DetachTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Detach[]
DetachTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) DispositionTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DispositionTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) End[]
EndTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) End[]
EndTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) ErrorConditionTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) ErrorConditionTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Flow[]
FlowTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Flow[]
FlowTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Open[]
OpenTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Open[]
OpenTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) Transfer[]
TransferTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Transfer[]
TransferTypeDecoder.readArrayElements
(ProtonBuffer buffer, DecoderState state, int count) AttachTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AttachTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) BeginTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BeginTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) CloseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) CloseTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DetachTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DetachTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) DispositionTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DispositionTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) EndTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) EndTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) ErrorConditionTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ErrorConditionTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) FlowTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FlowTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) OpenTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) OpenTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state) TransferTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TransferTypeDecoder.readValue
(ProtonBuffer buffer, DecoderState state)