Uses of Interface
org.apache.qpid.protonj2.codec.StreamDecoderState
-
-
Uses of StreamDecoderState in org.apache.qpid.protonj2.codec
Methods in org.apache.qpid.protonj2.codec that return StreamDecoderState Modifier and Type Method Description StreamDecoderState
StreamDecoder. getCachedDecoderState()
Return a singletonStreamDecoderState
instance that is meant to be shared within single threaded decoder interactions.StreamDecoderState
StreamDecoder. newDecoderState()
Creates a newStreamDecoderState
instance that can be used when interacting with the Decoder.StreamDecoderState
StreamDecoderState. reset()
Resets any intermediate state back to default values.Methods in org.apache.qpid.protonj2.codec with parameters of type StreamDecoderState Modifier and Type Method Description StreamTypeDecoder<?>
StreamDecoder. peekNextTypeDecoder(java.io.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(java.io.InputStream stream, StreamDecoderState state, int count)
Reads a series of this type that have been encoded into the body of an Array type.Binary
StreamDecoder. readBinary(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedBinary
value from the givenInputStream
assuming that the next value in the byte stream is that type.ProtonBuffer
StreamDecoder. readBinaryAsBuffer(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedBinary
value from the givenInputStream
assuming that the next value in the byte stream is that type.java.lang.Boolean
StreamDecoder. readBoolean(java.io.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(java.io.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.java.lang.Byte
StreamDecoder. readByte(java.io.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(java.io.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.java.lang.Character
StreamDecoder. readCharacter(java.io.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(java.io.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.Decimal128
StreamDecoder. readDecimal128(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedDecimal128
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decimal32
StreamDecoder. readDecimal32(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedDecimal32
value from the givenInputStream
assuming that the next value in the byte stream is that type.Decimal64
StreamDecoder. readDecimal64(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedDecimal64
value from the givenInputStream
assuming that the next value in the byte stream is that type.DeliveryTag
StreamDecoder. readDeliveryTag(java.io.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.java.lang.Double
StreamDecoder. readDouble(java.io.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(java.io.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.java.lang.Float
StreamDecoder. readFloat(java.io.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(java.io.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.java.lang.Integer
StreamDecoder. readInteger(java.io.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(java.io.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> java.util.List<V>
StreamDecoder. readList(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedList
value from the givenInputStream
assuming that the next value in the byte stream is that type.java.lang.Long
StreamDecoder. readLong(java.io.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(java.io.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>
java.util.Map<K,V>StreamDecoder. readMap(java.io.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(java.io.InputStream stream, StreamDecoderState state, java.lang.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.StreamTypeDecoder<?>
StreamDecoder. readNextTypeDecoder(java.io.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.java.lang.Object
StreamDecoder. readObject(java.io.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(java.io.InputStream stream, StreamDecoderState state, java.lang.Class<T> clazz)
Reads an encoded value from the givenInputStream
an return it as anObject
which the caller must then interpret.java.lang.Short
StreamDecoder. readShort(java.io.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(java.io.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.java.lang.String
StreamDecoder. readString(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedString
value from the givenInputStream
assuming that the next value in the byte stream is that type.Symbol
StreamDecoder. readSymbol(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedSymbol
value from the givenInputStream
assuming that the next value in the byte stream is that type.java.lang.String
StreamDecoder. readSymbol(java.io.InputStream stream, StreamDecoderState state, java.lang.String defaultValue)
Reads an encodedString
value from the givenInputStream
assuming that the next value in the byte stream is that type.java.lang.Long
StreamDecoder. readTimestamp(java.io.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(java.io.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.UnsignedByte
StreamDecoder. readUnsignedByte(java.io.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(java.io.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.UnsignedInteger
StreamDecoder. readUnsignedInteger(java.io.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(java.io.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(java.io.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.UnsignedLong
StreamDecoder. readUnsignedLong(java.io.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(java.io.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.UnsignedShort
StreamDecoder. readUnsignedShort(java.io.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(java.io.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(java.io.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.java.util.UUID
StreamDecoder. readUUID(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedUUID
value from the givenInputStream
assuming that the next value in the byte stream is that type.V
StreamTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Reads the next type from the given buffer and returns it.void
StreamTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Class Description class
ProtonStreamDecoderState
State object used by the Built in Decoder implementation.Methods in org.apache.qpid.protonj2.codec.decoders with parameters of type StreamDecoderState Modifier and Type Method Description StreamTypeDecoder<?>
ProtonStreamDecoder. peekNextTypeDecoder(java.io.InputStream stream, StreamDecoderState state)
V[]
AbstractPrimitiveTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DescribedType[]
UnknownDescribedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Binary
ProtonStreamDecoder. readBinary(java.io.InputStream stream, StreamDecoderState state)
ProtonBuffer
ProtonStreamDecoder. readBinaryAsBuffer(java.io.InputStream stream, StreamDecoderState state)
java.lang.Boolean
ProtonStreamDecoder. readBoolean(java.io.InputStream stream, StreamDecoderState state)
boolean
ProtonStreamDecoder. readBoolean(java.io.InputStream stream, StreamDecoderState state, boolean defaultValue)
java.lang.Byte
ProtonStreamDecoder. readByte(java.io.InputStream stream, StreamDecoderState state)
byte
ProtonStreamDecoder. readByte(java.io.InputStream stream, StreamDecoderState state, byte defaultValue)
java.lang.Character
ProtonStreamDecoder. readCharacter(java.io.InputStream stream, StreamDecoderState state)
char
ProtonStreamDecoder. readCharacter(java.io.InputStream stream, StreamDecoderState state, char defaultValue)
Decimal128
ProtonStreamDecoder. readDecimal128(java.io.InputStream stream, StreamDecoderState state)
Decimal32
ProtonStreamDecoder. readDecimal32(java.io.InputStream stream, StreamDecoderState state)
Decimal64
ProtonStreamDecoder. readDecimal64(java.io.InputStream stream, StreamDecoderState state)
DeliveryTag
ProtonStreamDecoder. readDeliveryTag(java.io.InputStream stream, StreamDecoderState state)
java.lang.Double
ProtonStreamDecoder. readDouble(java.io.InputStream stream, StreamDecoderState state)
double
ProtonStreamDecoder. readDouble(java.io.InputStream stream, StreamDecoderState state, double defaultValue)
java.lang.Float
ProtonStreamDecoder. readFloat(java.io.InputStream stream, StreamDecoderState state)
float
ProtonStreamDecoder. readFloat(java.io.InputStream stream, StreamDecoderState state, float defaultValue)
java.lang.Integer
ProtonStreamDecoder. readInteger(java.io.InputStream stream, StreamDecoderState state)
int
ProtonStreamDecoder. readInteger(java.io.InputStream stream, StreamDecoderState state, int defaultValue)
<V> java.util.List<V>
ProtonStreamDecoder. readList(java.io.InputStream stream, StreamDecoderState state)
java.lang.Long
ProtonStreamDecoder. readLong(java.io.InputStream stream, StreamDecoderState state)
long
ProtonStreamDecoder. readLong(java.io.InputStream stream, StreamDecoderState state, long defaultValue)
<K,V>
java.util.Map<K,V>ProtonStreamDecoder. readMap(java.io.InputStream stream, StreamDecoderState state)
<T> T[]
ProtonStreamDecoder. readMultiple(java.io.InputStream stream, StreamDecoderState state, java.lang.Class<T> clazz)
StreamTypeDecoder<?>
ProtonStreamDecoder. readNextTypeDecoder(java.io.InputStream stream, StreamDecoderState state)
java.lang.Object
ProtonStreamDecoder. readObject(java.io.InputStream stream, StreamDecoderState state)
<T> T
ProtonStreamDecoder. readObject(java.io.InputStream stream, StreamDecoderState state, java.lang.Class<T> clazz)
java.lang.Short
ProtonStreamDecoder. readShort(java.io.InputStream stream, StreamDecoderState state)
short
ProtonStreamDecoder. readShort(java.io.InputStream stream, StreamDecoderState state, short defaultValue)
java.lang.String
ProtonStreamDecoder. readString(java.io.InputStream stream, StreamDecoderState state)
Symbol
ProtonStreamDecoder. readSymbol(java.io.InputStream stream, StreamDecoderState state)
java.lang.String
ProtonStreamDecoder. readSymbol(java.io.InputStream stream, StreamDecoderState state, java.lang.String defaultValue)
java.lang.Long
ProtonStreamDecoder. readTimestamp(java.io.InputStream stream, StreamDecoderState state)
long
ProtonStreamDecoder. readTimestamp(java.io.InputStream stream, StreamDecoderState state, long defaultValue)
UnsignedByte
ProtonStreamDecoder. readUnsignedByte(java.io.InputStream stream, StreamDecoderState state)
byte
ProtonStreamDecoder. readUnsignedByte(java.io.InputStream stream, StreamDecoderState state, byte defaultValue)
UnsignedInteger
ProtonStreamDecoder. readUnsignedInteger(java.io.InputStream stream, StreamDecoderState state)
int
ProtonStreamDecoder. readUnsignedInteger(java.io.InputStream stream, StreamDecoderState state, int defaultValue)
long
ProtonStreamDecoder. readUnsignedInteger(java.io.InputStream stream, StreamDecoderState state, long defaultValue)
UnsignedLong
ProtonStreamDecoder. readUnsignedLong(java.io.InputStream stream, StreamDecoderState state)
long
ProtonStreamDecoder. readUnsignedLong(java.io.InputStream stream, StreamDecoderState state, long defaultValue)
UnsignedShort
ProtonStreamDecoder. readUnsignedShort(java.io.InputStream stream, StreamDecoderState state)
int
ProtonStreamDecoder. readUnsignedShort(java.io.InputStream stream, StreamDecoderState state, int defaultValue)
short
ProtonStreamDecoder. readUnsignedShort(java.io.InputStream stream, StreamDecoderState state, short defaultValue)
java.util.UUID
ProtonStreamDecoder. readUUID(java.io.InputStream stream, StreamDecoderState state)
DescribedType
UnknownDescribedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
void
UnknownDescribedTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Method Description Accepted[]
AcceptedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
AmqpSequence[]
AmqpSequenceTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
AmqpValue[]
AmqpValueTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
ApplicationProperties[]
ApplicationPropertiesTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Data[]
DataTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DeleteOnClose[]
DeleteOnCloseTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DeleteOnNoLinksOrMessages[]
DeleteOnNoLinksOrMessagesTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DeleteOnNoLinks[]
DeleteOnNoLinksTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DeleteOnNoMessages[]
DeleteOnNoMessagesTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
DeliveryAnnotations[]
DeliveryAnnotationsTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Footer[]
FooterTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Header[]
HeaderTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
MessageAnnotations[]
MessageAnnotationsTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Modified[]
ModifiedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Properties[]
PropertiesTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Received[]
ReceivedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Rejected[]
RejectedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Released[]
ReleasedTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Source[]
SourceTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Target[]
TargetTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Accepted
AcceptedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
AmqpSequence
AmqpSequenceTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
AmqpValue
AmqpValueTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
ApplicationProperties
ApplicationPropertiesTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Data
DataTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
DeleteOnClose
DeleteOnCloseTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
DeleteOnNoLinksOrMessages
DeleteOnNoLinksOrMessagesTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
DeleteOnNoLinks
DeleteOnNoLinksTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
DeleteOnNoMessages
DeleteOnNoMessagesTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
DeliveryAnnotations
DeliveryAnnotationsTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Footer
FooterTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Header
HeaderTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
MessageAnnotations
MessageAnnotationsTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Modified
ModifiedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Properties
PropertiesTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Received
ReceivedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Rejected
RejectedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Released
ReleasedTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Source
SourceTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Target
TargetTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
void
AcceptedTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AmqpSequenceTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AmqpValueTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ApplicationPropertiesTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DataTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeleteOnCloseTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeleteOnNoLinksOrMessagesTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeleteOnNoLinksTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeleteOnNoMessagesTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeliveryAnnotationsTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
FooterTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
HeaderTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
MessageAnnotationsTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ModifiedTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
PropertiesTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ReceivedTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
RejectedTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ReleasedTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
SourceTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
TargetTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Method Description boolean
BooleanFalseTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
boolean
BooleanTrueTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
boolean
BooleanTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.byte
ByteTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.char
CharacterTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.double
DoubleTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.float
FloatTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.int
Integer32TypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.int
Integer8TypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.long
Long8TypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
long
LongTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.short
ShortTypeDecoder. readPrimitiveValue(java.io.InputStream stream, StreamDecoderState state)
Reads the primitive value from the givenInputStream
and returns it.java.lang.String
AbstractSymbolTypeDecoder. readString(java.io.InputStream stream, StreamDecoderState state)
Reads a String view of an encoded Symbol value from the given buffer.java.lang.Object
AbstractArrayTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Binary
AbstractBinaryTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.util.List<java.lang.Object>
AbstractListTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.util.Map<java.lang.Object,java.lang.Object>
AbstractMapTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.String
AbstractStringTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Symbol
AbstractSymbolTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Boolean
BooleanFalseTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Boolean
BooleanTrueTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Boolean
BooleanTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Byte
ByteTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Character
CharacterTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Decimal128
Decimal128TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Decimal32
Decimal32TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Decimal64
Decimal64TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Double
DoubleTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Float
FloatTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Integer
Integer32TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Integer
Integer8TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.util.List<java.lang.Object>
List0TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Long
Long8TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Long
LongTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Void
NullTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Short
ShortTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.lang.Long
TimestampTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedByte
UnsignedByteTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedInteger
UnsignedInteger0TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedInteger
UnsignedInteger32TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedInteger
UnsignedInteger8TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedLong
UnsignedLong0TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedLong
UnsignedLong64TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedLong
UnsignedLong8TypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
UnsignedShort
UnsignedShortTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
java.util.UUID
UUIDTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
byte[]
AbstractBinaryTypeDecoder. readValueAsArray(java.io.InputStream stream, StreamDecoderState state)
Read and decode an AMQPBinary
into a byte array instance and return it.ProtonBuffer
AbstractBinaryTypeDecoder. readValueAsBuffer(java.io.InputStream stream, StreamDecoderState state)
Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.void
AbstractArrayTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AbstractBinaryTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AbstractListTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AbstractMapTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AbstractStringTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
AbstractSymbolTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
BooleanFalseTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
BooleanTrueTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
BooleanTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ByteTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
CharacterTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Decimal128TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Decimal32TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Decimal64TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DoubleTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
FloatTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Integer32TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Integer8TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
List0TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
Long8TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
LongTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
NullTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ShortTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
TimestampTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedByteTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedInteger0TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedInteger32TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedInteger8TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedLong0TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedLong64TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedLong8TypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UnsignedShortTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
UUIDTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Method Description SaslChallenge[]
SaslChallengeTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
SaslInit[]
SaslInitTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
SaslMechanisms[]
SaslMechanismsTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
SaslOutcome[]
SaslOutcomeTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
SaslResponse[]
SaslResponseTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
SaslChallenge
SaslChallengeTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
SaslInit
SaslInitTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
SaslMechanisms
SaslMechanismsTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
SaslOutcome
SaslOutcomeTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
SaslResponse
SaslResponseTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
void
SaslChallengeTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
SaslInitTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
SaslMechanismsTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
SaslOutcomeTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
SaslResponseTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Method Description Coordinator[]
CoordinatorTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Declared[]
DeclaredTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Declare[]
DeclareTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Discharge[]
DischargeTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
TransactionalState[]
TransactionStateTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Coordinator
CoordinatorTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Declared
DeclaredTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Declare
DeclareTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Discharge
DischargeTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
TransactionalState
TransactionStateTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
void
CoordinatorTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeclaredTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DeclareTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DischargeTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
TransactionStateTypeDecoder. skipValue(java.io.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 StreamDecoderState Modifier and Type Method Description Attach[]
AttachTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Begin[]
BeginTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Close[]
CloseTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Detach[]
DetachTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Disposition[]
DispositionTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
End[]
EndTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
ErrorCondition[]
ErrorConditionTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Flow[]
FlowTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Open[]
OpenTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Transfer[]
TransferTypeDecoder. readArrayElements(java.io.InputStream stream, StreamDecoderState state, int count)
Attach
AttachTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Begin
BeginTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Close
CloseTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Detach
DetachTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Disposition
DispositionTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
End
EndTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
ErrorCondition
ErrorConditionTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Flow
FlowTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Open
OpenTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
Transfer
TransferTypeDecoder. readValue(java.io.InputStream stream, StreamDecoderState state)
void
AttachTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
BeginTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
CloseTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DetachTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
DispositionTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
EndTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
ErrorConditionTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
FlowTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
OpenTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
void
TransferTypeDecoder. skipValue(java.io.InputStream stream, StreamDecoderState state)
-