Uses of Interface
org.apache.qpid.protonj2.codec.StreamDecoderState

Packages that use StreamDecoderState

Package	Description
org.apache.qpid.protonj2.codec
org.apache.qpid.protonj2.codec.decoders
org.apache.qpid.protonj2.codec.decoders.messaging
org.apache.qpid.protonj2.codec.decoders.primitives
org.apache.qpid.protonj2.codec.decoders.security
org.apache.qpid.protonj2.codec.decoders.transactions
org.apache.qpid.protonj2.codec.decoders.transport

Uses of StreamDecoderState in org.apache.qpid.protonj2.codec

Methods in org.apache.qpid.protonj2.codec that return StreamDecoderState

Modifier and Type	Method	Description
default StreamDecoderState	StreamDecoderState.decreaseDepth()	During decode as on level of complex type decode completes the level value is decreased
StreamDecoderState	StreamDecoder.getCachedDecoderState()	Return a singleton StreamDecoderState instance that is meant to be shared within single threaded decoder interactions.
default StreamDecoderState	StreamDecoderState.increaseDepth()	During decode of AMQP types which can be comprised of a nesting of other AMQP types the depth is increased to track the amount of type nesting that comprises the type being decoded.
StreamDecoderState	StreamDecoder.newDecoderState()	Creates a new StreamDecoderState instance that can be used when interacting with the Decoder.
StreamDecoderState	StreamDecoderState.reset()	Resets any intermediate state back to default values.
default StreamDecoderState	StreamDecoderState.setDepthLimit(int limit)	Sets the configured maximum depth that nested types such as Lists, Maps and Arrays can have before a DecodeException is thrown to allow the decoder to errors in cases where the depth of encoding exceeds that the environment can support.
default StreamDecoderState	StreamDecoderState.setMaxArraySize(int maximumSize)	Sets the configured maximum size of an encoded array this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxBinarySize(int maximumSize)	Gets the configured maximum size of an encoded Binary this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxListSize(int maximumSize)	Sets the configured maximum indicated encoded size of a List this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxMapSize(int maximumSize)	Sets the configured maximum indicated encoded size of a Map this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxStringSize(int maximumSize)	Sets the configured maximum size of an encoded string this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxSymbolSize(int maximumSize)	Gets the configured maximum length of an encoded Symbol this decoder will allow before it throws an DecodeException to indicate that a rule violation has occurred.
default StreamDecoderState	StreamDecoderState.setMaxZeroWidthArrayElements(int maxElements)	Sets the configured maximum number of elements that can be decoded from an array encoded with the zero width AMQP types (Null, UInt0.

Methods in org.apache.qpid.protonj2.codec with parameters of type StreamDecoderState

Modifier and Type	Method	Description
StreamTypeDecoder<?>	StreamDecoder.peekNextTypeDecoder(InputStream stream, StreamDecoderState state)	Peeks ahead in the given InputStream instance and returns a TypeDecoder 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.
Binary	StreamDecoder.readBinary(InputStream stream, StreamDecoderState state)	Reads an encoded Binary value from the given InputStream assuming that the next value in the byte stream is that type.
ProtonBuffer	StreamDecoder.readBinaryAsBuffer(InputStream stream, StreamDecoderState state)	Reads an encoded Binary value from the given InputStream assuming that the next value in the byte stream is that type.
Boolean	StreamDecoder.readBoolean(InputStream stream, StreamDecoderState state)	Reads an encoded Boolean value from the given InputStream assuming that the next value in the byte stream is that type.
boolean	StreamDecoder.readBoolean(InputStream stream, StreamDecoderState state, boolean defaultValue)	Reads an encoded Byte value from the given InputStream assuming that the next value in the byte stream is that type.
Byte	StreamDecoder.readByte(InputStream stream, StreamDecoderState state)	Reads an encoded Byte value from the given InputStream assuming that the next value in the byte stream is that type.
byte	StreamDecoder.readByte(InputStream stream, StreamDecoderState state, byte defaultValue)	Reads an encoded Byte value from the given InputStream assuming that the next value in the byte stream is that type.
Character	StreamDecoder.readCharacter(InputStream stream, StreamDecoderState state)	Reads an encoded Character value from the given InputStream assuming that the next value in the byte stream is that type.
char	StreamDecoder.readCharacter(InputStream stream, StreamDecoderState state, char defaultValue)	Reads an encoded Character value from the given InputStream assuming that the next value in the byte stream is that type.
Decimal128	StreamDecoder.readDecimal128(InputStream stream, StreamDecoderState state)	Reads an encoded Decimal128 value from the given InputStream assuming that the next value in the byte stream is that type.
Decimal32	StreamDecoder.readDecimal32(InputStream stream, StreamDecoderState state)	Reads an encoded Decimal32 value from the given InputStream assuming that the next value in the byte stream is that type.
Decimal64	StreamDecoder.readDecimal64(InputStream stream, StreamDecoderState state)	Reads an encoded Decimal64 value from the given InputStream assuming that the next value in the byte stream is that type.
DeliveryTag	StreamDecoder.readDeliveryTag(InputStream stream, StreamDecoderState state)	This method expects to read a Binary encoded type from the provided stream and constructs a DeliveryTag type that wraps the bytes encoded.
Double	StreamDecoder.readDouble(InputStream stream, StreamDecoderState state)	Reads an encoded Double value from the given InputStream assuming that the next value in the byte stream is that type.
double	StreamDecoder.readDouble(InputStream stream, StreamDecoderState state, double defaultValue)	Reads an encoded Double value from the given InputStream assuming that the next value in the byte stream is that type.
Float	StreamDecoder.readFloat(InputStream stream, StreamDecoderState state)	Reads an encoded Float value from the given InputStream assuming that the next value in the byte stream is that type.
float	StreamDecoder.readFloat(InputStream stream, StreamDecoderState state, float defaultValue)	Reads an encoded Float value from the given InputStream assuming that the next value in the byte stream is that type.
Integer	StreamDecoder.readInteger(InputStream stream, StreamDecoderState state)	Reads an encoded Integer value from the given InputStream assuming that the next value in the byte stream is that type.
int	StreamDecoder.readInteger(InputStream stream, StreamDecoderState state, int defaultValue)	Reads an encoded Integer value from the given InputStream assuming that the next value in the byte stream is that type.
<V> List<V>	StreamDecoder.readList(InputStream stream, StreamDecoderState state)	Reads an encoded List value from the given InputStream assuming that the next value in the byte stream is that type.
Long	StreamDecoder.readLong(InputStream stream, StreamDecoderState state)	Reads an encoded Long value from the given InputStream assuming that the next value in the byte stream is that type.
long	StreamDecoder.readLong(InputStream stream, StreamDecoderState state, long defaultValue)	Reads an encoded Long value from the given InputStream 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 encoded Map value from the given InputStream 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 given InputStream an return it as an array of Object instances which the caller must then interpret.
StreamTypeDecoder<?>	StreamDecoder.readNextTypeDecoder(InputStream stream, StreamDecoderState state)	Reads from the given InputStream instance and returns a StreamTypeDecoder that can read the next encoded AMQP type from the stream's bytes.
Object	StreamDecoder.readObject(InputStream stream, StreamDecoderState state)	Reads an encoded value from the given InputStream an return it as an Object which the caller must then interpret.
<T> T	StreamDecoder.readObject(InputStream stream, StreamDecoderState state, Class<T> clazz)	Reads an encoded value from the given InputStream an return it as an Object which the caller must then interpret.
Short	StreamDecoder.readShort(InputStream stream, StreamDecoderState state)	Reads an encoded Short value from the given InputStream assuming that the next value in the byte stream is that type.
short	StreamDecoder.readShort(InputStream stream, StreamDecoderState state, short defaultValue)	Reads an encoded Short value from the given InputStream 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 given InputStream and returns it.
String	StreamDecoder.readString(InputStream stream, StreamDecoderState state)	Reads an encoded String value from the given InputStream assuming that the next value in the byte stream is that type.
Symbol	StreamDecoder.readSymbol(InputStream stream, StreamDecoderState state)	Reads an encoded Symbol value from the given InputStream assuming that the next value in the byte stream is that type.
String	StreamDecoder.readSymbol(InputStream stream, StreamDecoderState state, String defaultValue)	Reads an encoded String value from the given InputStream assuming that the next value in the byte stream is that type.
Long	StreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state)	Reads an encoded AMQP time stamp value from the given InputStream 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 given InputStream assuming that the next value in the byte stream is that type.
UnsignedByte	StreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state)	Reads an encoded UnsignedByte value from the given InputStream assuming that the next value in the byte stream is that type.
byte	StreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state, byte defaultValue)	Reads an encoded UnsignedByte value from the given InputStream assuming that the next value in the byte stream is that type.
UnsignedInteger	StreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state)	Reads an encoded UnsignedInteger value from the given InputStream assuming that the next value in the byte stream is that type.
int	StreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, int defaultValue)	Reads an encoded UnsignedInteger value from the given InputStream assuming that the next value in the byte stream is that type.
long	StreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, long defaultValue)	Reads an encoded UnsignedInteger value from the given InputStream assuming that the next value in the byte stream is that type.
UnsignedLong	StreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state)	Reads an encoded UnsignedLong value from the given InputStream assuming that the next value in the byte stream is that type.
long	StreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state, long defaultValue)	Reads an encoded UnsignedLong value from the given InputStream assuming that the next value in the byte stream is that type.
UnsignedShort	StreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state)	Reads an encoded UnsignedShort value from the given InputStream assuming that the next value in the byte stream is that type.
int	StreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, int defaultValue)	Reads an encoded UnsignedShort value from the given InputStream assuming that the next value in the byte stream is that type.
short	StreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, short defaultValue)	Reads an encoded UnsignedShort value from the given InputStream assuming that the next value in the byte stream is that type.
UUID	StreamDecoder.readUUID(InputStream stream, StreamDecoderState state)	Reads an encoded UUID value from the given InputStream assuming that the next value in the byte stream is that type.
V	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 StreamDecoderState

Modifier and Type	Class	Description
final 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(InputStream stream, StreamDecoderState state)
final V[]	AbstractDescribedListTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
final D[]	AbstractDescribedMapTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
V[]	AbstractPrimitiveTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
final DescribedType[]	UnknownDescribedTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
Binary	ProtonStreamDecoder.readBinary(InputStream stream, StreamDecoderState state)
ProtonBuffer	ProtonStreamDecoder.readBinaryAsBuffer(InputStream stream, StreamDecoderState state)
Boolean	ProtonStreamDecoder.readBoolean(InputStream stream, StreamDecoderState state)
boolean	ProtonStreamDecoder.readBoolean(InputStream stream, StreamDecoderState state, boolean defaultValue)
Byte	ProtonStreamDecoder.readByte(InputStream stream, StreamDecoderState state)
byte	ProtonStreamDecoder.readByte(InputStream stream, StreamDecoderState state, byte defaultValue)
Character	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 given InputStream and returns it.
Decimal128	ProtonStreamDecoder.readDecimal128(InputStream stream, StreamDecoderState state)
Decimal32	ProtonStreamDecoder.readDecimal32(InputStream stream, StreamDecoderState state)
Decimal64	ProtonStreamDecoder.readDecimal64(InputStream stream, StreamDecoderState state)
DeliveryTag	ProtonStreamDecoder.readDeliveryTag(InputStream stream, StreamDecoderState state)
Double	ProtonStreamDecoder.readDouble(InputStream stream, StreamDecoderState state)
double	ProtonStreamDecoder.readDouble(InputStream stream, StreamDecoderState state, double defaultValue)
Float	ProtonStreamDecoder.readFloat(InputStream stream, StreamDecoderState state)
float	ProtonStreamDecoder.readFloat(InputStream stream, StreamDecoderState state, float defaultValue)
Integer	ProtonStreamDecoder.readInteger(InputStream stream, StreamDecoderState state)
int	ProtonStreamDecoder.readInteger(InputStream stream, StreamDecoderState state, int defaultValue)
protected abstract K	AbstractDescribedMapTypeDecoder.readKey(InputStream stream, StreamDecoder decoder, StreamDecoderState state)	Called during decoding of the described Map body to allow the implementation to read the map key using the optimal decoder API for the type of key stored in the map.
<V> List<V>	ProtonStreamDecoder.readList(InputStream stream, StreamDecoderState state)
Long	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)
StreamTypeDecoder<?>	ProtonStreamDecoder.readNextTypeDecoder(InputStream stream, StreamDecoderState state)
Object	ProtonStreamDecoder.readObject(InputStream stream, StreamDecoderState state)
<T> T	ProtonStreamDecoder.readObject(InputStream stream, StreamDecoderState state, Class<T> clazz)
default Object	PrimitiveTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)	Read and return a Java primitive type array from the given stream of bytes up to the given count of elements.
Short	ProtonStreamDecoder.readShort(InputStream stream, StreamDecoderState state)
short	ProtonStreamDecoder.readShort(InputStream stream, StreamDecoderState state, short defaultValue)
protected V	AbstractDescribedListTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)	Reads a single instance of the described list type using the provided decoder.
int	AbstractDescribedTypeDecoder.readSize(InputStream stream, StreamDecoderState state)
String	ProtonStreamDecoder.readString(InputStream stream, StreamDecoderState state)
Symbol	ProtonStreamDecoder.readSymbol(InputStream stream, StreamDecoderState state)
String	ProtonStreamDecoder.readSymbol(InputStream stream, StreamDecoderState state, String defaultValue)
Long	ProtonStreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state)
long	ProtonStreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state, long defaultValue)
protected abstract V	AbstractDescribedListTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)	Reads the actual type from the byte stream with the given number of encoded list elements populated
UnsignedByte	ProtonStreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state)
byte	ProtonStreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state, byte defaultValue)
UnsignedInteger	ProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state)
int	ProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, int defaultValue)
long	ProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, long defaultValue)
UnsignedLong	ProtonStreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state)
long	ProtonStreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state, long defaultValue)
UnsignedShort	ProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state)
int	ProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, int defaultValue)
short	ProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, short defaultValue)
UUID	ProtonStreamDecoder.readUUID(InputStream stream, StreamDecoderState state)
final V	AbstractDescribedListTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
final D	AbstractDescribedMapTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Object	PrimitiveArrayTypeDecoder.readValue(InputStream stream, StreamDecoderState state, Class<?> ofType)	Reads the given array from the bytes in the buffer but only if the type encoding of the given array matches the given Class filter.
final DescribedType	UnknownDescribedTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
protected void	AbstractDescribedMapTypeDecoder.scanMapEntries(InputStream stream, StreamDecoderState state, StreamScanningContext<K> context, BiConsumer<K,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)
protected static final int	AbstractDescribedMapTypeDecoder.validateAndGetCount(int size, InputStream stream, StreamDecoderState state, MapTypeDecoder decoder)
static void	PrimitiveArrayTypeDecoder.validateArrayConstraints(int count, InputStream stream, StreamDecoderState state, PrimitiveTypeDecoder<?> decoder)	Validates the basic requirements for the count field of an array encoding.

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
AmqpSequence[]	AmqpSequenceTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
AmqpValue[]	AmqpValueTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
Data[]	DataTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
protected String	ApplicationPropertiesTypeDecoder.readKey(InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Symbol	DeliveryAnnotationsTypeDecoder.readKey(InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Symbol	FooterTypeDecoder.readKey(InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Symbol	MessageAnnotationsTypeDecoder.readKey(InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Accepted	AcceptedTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected DeleteOnClose	DeleteOnCloseTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected DeleteOnNoLinksOrMessages	DeleteOnNoLinksOrMessagesTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected DeleteOnNoLinks	DeleteOnNoLinksTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected DeleteOnNoMessages	DeleteOnNoMessagesTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected Released	ReleasedTypeDecoder.readSingle(InputStream stream, StreamDecoderState state, ListTypeDecoder listDecoder)
protected Accepted	AcceptedTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected DeleteOnClose	DeleteOnCloseTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected DeleteOnNoLinksOrMessages	DeleteOnNoLinksOrMessagesTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected DeleteOnNoLinks	DeleteOnNoLinksTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected DeleteOnNoMessages	DeleteOnNoMessagesTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Header	HeaderTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Modified	ModifiedTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Properties	PropertiesTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Received	ReceivedTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Rejected	RejectedTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Released	ReleasedTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Source	SourceTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Target	TargetTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
AmqpSequence	AmqpSequenceTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
AmqpValue	AmqpValueTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Data	DataTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
void	DeliveryAnnotationsTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded DeliveryAnnotations map looking for keys that match with the provided ScanningContext.
void	FooterTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded Footer map looking for keys that match with the provided ScanningContext.
void	MessageAnnotationsTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded MessageAnnotations map looking for keys that match with the provided ScanningContext.
void	ApplicationPropertiesTypeDecoder.scanProperties(InputStream stream, StreamDecoderState state, StreamScanningContext<String> context, BiConsumer<String,Object> matchConsumer)	Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext.
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

Methods in org.apache.qpid.protonj2.codec.decoders.primitives with parameters of type StreamDecoderState

Modifier and Type	Method	Description
Boolean[]	BooleanFalseTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
Boolean[]	BooleanTrueTypeDecoder.readArrayElements(InputStream stream, StreamDecoderState state, int count)
int	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 provided InputStream.
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.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
boolean[]	BooleanTrueTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
boolean[]	BooleanTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
byte[]	ByteTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
char[]	CharacterTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
double[]	DoubleTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
float[]	FloatTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
int[]	Integer32TypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
int[]	Integer8TypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
long[]	Long8TypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
long[]	LongTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
short[]	ShortTypeDecoder.readPrimitiveArray(InputStream stream, StreamDecoderState state, int count)
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 given InputStream and returns it.
byte	ByteTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
char	CharacterTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
double	DoubleTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
float	FloatTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
int	Integer32TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
int	Integer8TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
long	Long8TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
long	LongTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream and returns it.
short	ShortTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state)	Reads the primitive value from the given InputStream 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	SaslSymbol32TypeDecoder.readSize(InputStream stream, StreamDecoderState state)
int	SaslSymbol8TypeDecoder.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)
String	AbstractSymbolTypeDecoder.readString(InputStream stream, StreamDecoderState state)	Reads a String view of an encoded Symbol value from the given buffer.
Object	AbstractArrayTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Object	AbstractArrayTypeDecoder.readValue(InputStream stream, StreamDecoderState state, Class<?> ofType)
Binary	AbstractBinaryTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
List<Object>	AbstractListTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Map<Object,Object>	AbstractMapTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
String	AbstractStringTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Symbol	AbstractSymbolTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Boolean	BooleanFalseTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Boolean	BooleanTrueTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Boolean	BooleanTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Byte	ByteTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Character	CharacterTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Decimal128	Decimal128TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Decimal32	Decimal32TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Decimal64	Decimal64TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Double	DoubleTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Float	FloatTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Integer	Integer32TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Integer	Integer8TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
List<Object>	List0TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Long	Long8TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Long	LongTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Void	NullTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Short	ShortTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
Long	TimestampTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedByte	UnsignedByteTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedInteger	UnsignedInteger0TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedInteger	UnsignedInteger32TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedInteger	UnsignedInteger8TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedLong	UnsignedLong0TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedLong	UnsignedLong64TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedLong	UnsignedLong8TypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UnsignedShort	UnsignedShortTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
UUID	UUIDTypeDecoder.readValue(InputStream stream, StreamDecoderState state)
byte[]	AbstractBinaryTypeDecoder.readValueAsArray(InputStream stream, StreamDecoderState state)	Read and decode an AMQP Binary into a byte array instance and return it.
byte[]	BinaryTypeDecoder.readValueAsArray(InputStream stream, StreamDecoderState state)	Read and decode an AMQP Binary into a byte array instance and return it.
ProtonBuffer	AbstractBinaryTypeDecoder.readValueAsBuffer(InputStream stream, StreamDecoderState state)	Read and decode an AMQP Binary into a ProtonBuffer instance and return it.
ProtonBuffer	BinaryTypeDecoder.readValueAsBuffer(InputStream stream, StreamDecoderState state)	Read and decode an AMQP Binary into a ProtonBuffer 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 encoded Map 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

Methods in org.apache.qpid.protonj2.codec.decoders.security with parameters of type StreamDecoderState

Modifier and Type	Method	Description
protected SaslChallenge	SaslChallengeTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected SaslInit	SaslInitTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected SaslMechanisms	SaslMechanismsTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected SaslOutcome	SaslOutcomeTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected SaslResponse	SaslResponseTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, 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
protected Coordinator	CoordinatorTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Declared	DeclaredTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Declare	DeclareTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Discharge	DischargeTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected TransactionalState	TransactionStateTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, 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
protected Attach	AttachTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Begin	BeginTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Close	CloseTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Detach	DetachTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Disposition	DispositionTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected End	EndTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected ErrorCondition	ErrorConditionTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Flow	FlowTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Open	OpenTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)
protected Transfer	TransferTypeDecoder.readType(int count, InputStream stream, StreamDecoder decoder, StreamDecoderState state)