Uses of Interface
org.apache.qpid.protonj2.codec.StreamDecoderState
Package
Description
-
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec
Modifier and TypeMethodDescriptionStreamDecoder.getCachedDecoderState()
Return a singletonStreamDecoderState
instance that is meant to be shared within single threaded decoder interactions.StreamDecoder.newDecoderState()
Creates a newStreamDecoderState
instance that can be used when interacting with the Decoder.StreamDecoderState.reset()
Resets any intermediate state back to default values.Modifier and TypeMethodDescriptionStreamDecoder.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.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.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.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.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.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.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.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.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.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.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.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.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> 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.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> 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[]
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.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.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.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.int
StreamTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) Reads the size in bytes of the encoded primitive from the givenInputStream
and returns it.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.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.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.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.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.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.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.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.void
StreamTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) Skips over the bytes that compose the type this descriptor decodes. -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders
Modifier and TypeClassDescriptionfinal class
State object used by the Built in Decoder implementation.Modifier and TypeMethodDescriptionProtonStreamDecoder.peekNextTypeDecoder
(InputStream stream, StreamDecoderState state) V[]
AbstractPrimitiveTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) final DescribedType[]
UnknownDescribedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) ProtonStreamDecoder.readBinary
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readBinaryAsBuffer
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state) boolean
ProtonStreamDecoder.readBoolean
(InputStream stream, StreamDecoderState state, boolean defaultValue) ProtonStreamDecoder.readByte
(InputStream stream, StreamDecoderState state) byte
ProtonStreamDecoder.readByte
(InputStream stream, StreamDecoderState state, byte defaultValue) ProtonStreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state) char
ProtonStreamDecoder.readCharacter
(InputStream stream, StreamDecoderState state, char defaultValue) int
PrimitiveArrayTypeDecoder.readCount
(InputStream stream, StreamDecoderState state) Reads the number of elements in the encoded primitive from the givenInputStream
and returns it.ProtonStreamDecoder.readDecimal128
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDecimal32
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDecimal64
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDeliveryTag
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDouble
(InputStream stream, StreamDecoderState state) double
ProtonStreamDecoder.readDouble
(InputStream stream, StreamDecoderState state, double defaultValue) ProtonStreamDecoder.readFloat
(InputStream stream, StreamDecoderState state) float
ProtonStreamDecoder.readFloat
(InputStream stream, StreamDecoderState state, float defaultValue) ProtonStreamDecoder.readInteger
(InputStream stream, StreamDecoderState state) int
ProtonStreamDecoder.readInteger
(InputStream stream, StreamDecoderState state, int defaultValue) <V> List
<V> ProtonStreamDecoder.readList
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readLong
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readLong
(InputStream stream, StreamDecoderState state, long defaultValue) <K,
V> Map <K, V> ProtonStreamDecoder.readMap
(InputStream stream, StreamDecoderState state) <T> T[]
ProtonStreamDecoder.readMultiple
(InputStream stream, StreamDecoderState state, Class<T> clazz) ProtonStreamDecoder.readNextTypeDecoder
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readObject
(InputStream stream, StreamDecoderState state) <T> T
ProtonStreamDecoder.readObject
(InputStream stream, StreamDecoderState state, Class<T> clazz) ProtonStreamDecoder.readShort
(InputStream stream, StreamDecoderState state) short
ProtonStreamDecoder.readShort
(InputStream stream, StreamDecoderState state, short defaultValue) int
AbstractDescribedTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readString
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readSymbol
(InputStream stream, StreamDecoderState state, String defaultValue) ProtonStreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readTimestamp
(InputStream stream, StreamDecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state) byte
ProtonStreamDecoder.readUnsignedByte
(InputStream stream, StreamDecoderState state, byte 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) ProtonStreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state) long
ProtonStreamDecoder.readUnsignedLong
(InputStream stream, StreamDecoderState state, long 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) ProtonStreamDecoder.readUUID
(InputStream stream, StreamDecoderState state) final DescribedType
UnknownDescribedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) protected <KeyType> void
AbstractDescribedMapTypeDecoder.scanMapEntries
(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) final void
AbstractDescribedListTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) final void
AbstractDescribedMapTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) final void
UnknownDescribedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.messaging
Modifier and TypeMethodDescriptionAccepted[]
AcceptedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AmqpSequenceTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AmqpValueTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) ApplicationPropertiesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Data[]
DataTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnCloseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoLinksOrMessagesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoLinksTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeleteOnNoMessagesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DeliveryAnnotationsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Footer[]
FooterTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Header[]
HeaderTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) MessageAnnotationsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Modified[]
ModifiedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) PropertiesTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Received[]
ReceivedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Rejected[]
RejectedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Released[]
ReleasedTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Source[]
SourceTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Target[]
TargetTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AcceptedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AmqpSequenceTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AmqpValueTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ApplicationPropertiesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DataTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnCloseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoLinksOrMessagesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoLinksTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeleteOnNoMessagesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeliveryAnnotationsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FooterTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) HeaderTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) MessageAnnotationsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ModifiedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) PropertiesTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ReceivedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) RejectedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ReleasedTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SourceTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TargetTypeDecoder.readValue
(InputStream stream, StreamDecoderState 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
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
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
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
AmqpSequenceTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AmqpValueTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DataTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.primitives
Modifier and TypeMethodDescriptionint
Array32TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
Array8TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List0TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List32TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
List8TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
ListTypeDecoder.readCount
(InputStream stream, StreamDecoderState state) Reads the number of elements contained in the encoded list from the providedInputStream
.int
Map32TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
Map8TypeDecoder.readCount
(InputStream stream, StreamDecoderState state) int
MapTypeDecoder.readCount
(InputStream stream, StreamDecoderState state) Reads the count of entries in the encoded Map.boolean
BooleanFalseTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) boolean
BooleanTrueTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) boolean
BooleanTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.byte
ByteTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.char
CharacterTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.double
DoubleTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.float
FloatTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.int
Integer32TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.int
Integer8TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.long
Long8TypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) long
LongTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.short
ShortTypeDecoder.readPrimitiveValue
(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStream
and returns it.int
Array32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Array8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Binary32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Binary8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
BooleanFalseTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
BooleanTrueTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
BooleanTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
ByteTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
CharacterTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Decimal128TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Decimal32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Decimal64TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
DoubleTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
FloatTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Integer32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Integer8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List0TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
List8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Long8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
LongTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Map32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Map8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
NullTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
ShortTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
String32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
String8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Symbol32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
Symbol8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
TimestampTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedByteTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedInteger0TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedInteger32TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedInteger8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedLong0TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedLong64TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedLong8TypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UnsignedShortTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) int
UUIDTypeDecoder.readSize
(InputStream stream, StreamDecoderState state) AbstractSymbolTypeDecoder.readString
(InputStream stream, StreamDecoderState state) Reads a String view of an encoded Symbol value from the given buffer.AbstractArrayTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractBinaryTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractListTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractMapTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractStringTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) AbstractSymbolTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanFalseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanTrueTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BooleanTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ByteTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) CharacterTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal128TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Decimal64TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DoubleTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FloatTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Integer32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Integer8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) List0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) Long8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) LongTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) NullTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ShortTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TimestampTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedByteTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger32TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedInteger8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong0TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong64TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedLong8TypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UnsignedShortTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) UUIDTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) byte[]
AbstractBinaryTypeDecoder.readValueAsArray
(InputStream stream, StreamDecoderState 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.<KeyType> void
AbstractMapTypeDecoder.scanKeys
(InputStream stream, StreamDecoderState state, StreamScanningContext<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.void
AbstractArrayTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractBinaryTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractListTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractMapTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractStringTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AbstractSymbolTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanFalseTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanTrueTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BooleanTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ByteTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
CharacterTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal128TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Decimal64TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DoubleTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
FloatTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Integer32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Integer8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
List0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
Long8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
LongTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
NullTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ShortTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
TimestampTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedByteTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger32TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedInteger8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong0TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong64TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedLong8TypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UnsignedShortTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
UUIDTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.security
Modifier and TypeMethodDescriptionSaslChallengeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslInit[]
SaslInitTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslMechanismsTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslOutcomeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslResponseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) SaslChallengeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslInitTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslMechanismsTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslOutcomeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) SaslResponseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.transactions
Modifier and TypeMethodDescriptionCoordinatorTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Declared[]
DeclaredTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Declare[]
DeclareTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DischargeTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) TransactionStateTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) CoordinatorTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeclaredTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DeclareTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DischargeTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TransactionStateTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.transport
Modifier and TypeMethodDescriptionAttach[]
AttachTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Begin[]
BeginTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Close[]
CloseTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Detach[]
DetachTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) DispositionTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) End[]
EndTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) ErrorConditionTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Flow[]
FlowTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Open[]
OpenTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) Transfer[]
TransferTypeDecoder.readArrayElements
(InputStream stream, StreamDecoderState state, int count) AttachTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) BeginTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) CloseTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DetachTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) DispositionTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) EndTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) ErrorConditionTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) FlowTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) OpenTypeDecoder.readValue
(InputStream stream, StreamDecoderState state) TransferTypeDecoder.readValue
(InputStream stream, StreamDecoderState state)