Uses of Interface
org.apache.qpid.protonj2.codec.StreamDecoderState
Packages that use StreamDecoderState
Package
Description
-
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec
Methods in org.apache.qpid.protonj2.codec that return StreamDecoderStateModifier 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.Methods in org.apache.qpid.protonj2.codec with parameters of type StreamDecoderStateModifier 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.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
Classes in org.apache.qpid.protonj2.codec.decoders that implement StreamDecoderStateModifier and TypeClassDescriptionfinal class
State object used by the Built in Decoder implementation.Methods in org.apache.qpid.protonj2.codec.decoders with parameters of type StreamDecoderStateModifier 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) 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) 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) final void
UnknownDescribedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.messaging
Methods in org.apache.qpid.protonj2.codec.decoders.messaging with parameters of type StreamDecoderStateModifier 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
AcceptedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AmqpSequenceTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
AmqpValueTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ApplicationPropertiesTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DataTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeleteOnCloseTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeleteOnNoLinksOrMessagesTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeleteOnNoLinksTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeleteOnNoMessagesTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeliveryAnnotationsTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
FooterTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
HeaderTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
MessageAnnotationsTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ModifiedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
PropertiesTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ReceivedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
RejectedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ReleasedTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
SourceTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
TargetTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.primitives
Methods in org.apache.qpid.protonj2.codec.decoders.primitives with parameters of type StreamDecoderStateModifier and TypeMethodDescriptionboolean
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.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.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
Methods in org.apache.qpid.protonj2.codec.decoders.security with parameters of type StreamDecoderStateModifier 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) void
SaslChallengeTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
SaslInitTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
SaslMechanismsTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
SaslOutcomeTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
SaslResponseTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.transactions
Methods in org.apache.qpid.protonj2.codec.decoders.transactions with parameters of type StreamDecoderStateModifier 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) void
CoordinatorTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeclaredTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DeclareTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DischargeTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
TransactionStateTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) -
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec.decoders.transport
Methods in org.apache.qpid.protonj2.codec.decoders.transport with parameters of type StreamDecoderStateModifier 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) void
AttachTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
BeginTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
CloseTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DetachTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
DispositionTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
EndTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
ErrorConditionTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
FlowTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
OpenTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state) void
TransferTypeDecoder.skipValue
(InputStream stream, StreamDecoderState state)