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 singletonStreamDecoderStateinstance that is meant to be shared within single threaded decoder interactions.StreamDecoder.newDecoderState()Creates a newStreamDecoderStateinstance 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 givenInputStreaminstance and returns aTypeDecoderthat 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 encodedBinaryvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readBinaryAsBuffer(InputStream stream, StreamDecoderState state) Reads an encodedBinaryvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readBoolean(InputStream stream, StreamDecoderState state) Reads an encodedBooleanvalue from the givenInputStreamassuming that the next value in the byte stream is that type.booleanStreamDecoder.readBoolean(InputStream stream, StreamDecoderState state, boolean defaultValue) Reads an encodedBytevalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readByte(InputStream stream, StreamDecoderState state) Reads an encodedBytevalue from the givenInputStreamassuming that the next value in the byte stream is that type.byteStreamDecoder.readByte(InputStream stream, StreamDecoderState state, byte defaultValue) Reads an encodedBytevalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readCharacter(InputStream stream, StreamDecoderState state) Reads an encodedCharactervalue from the givenInputStreamassuming that the next value in the byte stream is that type.charStreamDecoder.readCharacter(InputStream stream, StreamDecoderState state, char defaultValue) Reads an encodedCharactervalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readDecimal128(InputStream stream, StreamDecoderState state) Reads an encodedDecimal128value from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readDecimal32(InputStream stream, StreamDecoderState state) Reads an encodedDecimal32value from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readDecimal64(InputStream stream, StreamDecoderState state) Reads an encodedDecimal64value from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readDeliveryTag(InputStream stream, StreamDecoderState state) This method expects to read aBinaryencoded type from the provided stream and constructs aDeliveryTagtype that wraps the bytes encoded.StreamDecoder.readDouble(InputStream stream, StreamDecoderState state) Reads an encodedDoublevalue from the givenInputStreamassuming that the next value in the byte stream is that type.doubleStreamDecoder.readDouble(InputStream stream, StreamDecoderState state, double defaultValue) Reads an encodedDoublevalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readFloat(InputStream stream, StreamDecoderState state) Reads an encodedFloatvalue from the givenInputStreamassuming that the next value in the byte stream is that type.floatStreamDecoder.readFloat(InputStream stream, StreamDecoderState state, float defaultValue) Reads an encodedFloatvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readInteger(InputStream stream, StreamDecoderState state) Reads an encodedIntegervalue from the givenInputStreamassuming that the next value in the byte stream is that type.intStreamDecoder.readInteger(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedIntegervalue from the givenInputStreamassuming that the next value in the byte stream is that type.<V> List<V>StreamDecoder.readList(InputStream stream, StreamDecoderState state) Reads an encodedListvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readLong(InputStream stream, StreamDecoderState state) Reads an encodedLongvalue from the givenInputStreamassuming that the next value in the byte stream is that type.longStreamDecoder.readLong(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedLongvalue from the givenInputStreamassuming that the next value in the byte stream is that type.<K,V> Map<K, V> StreamDecoder.readMap(InputStream stream, StreamDecoderState state) Reads an encodedMapvalue from the givenInputStreamassuming 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 givenInputStreaman return it as an array ofObjectinstances which the caller must then interpret.StreamDecoder.readNextTypeDecoder(InputStream stream, StreamDecoderState state) Reads from the givenInputStreaminstance and returns aStreamTypeDecoderthat can read the next encoded AMQP type from the stream's bytes.StreamDecoder.readObject(InputStream stream, StreamDecoderState state) Reads an encoded value from the givenInputStreaman return it as anObjectwhich the caller must then interpret.<T> TStreamDecoder.readObject(InputStream stream, StreamDecoderState state, Class<T> clazz) Reads an encoded value from the givenInputStreaman return it as anObjectwhich the caller must then interpret.StreamDecoder.readShort(InputStream stream, StreamDecoderState state) Reads an encodedShortvalue from the givenInputStreamassuming that the next value in the byte stream is that type.shortStreamDecoder.readShort(InputStream stream, StreamDecoderState state, short defaultValue) Reads an encodedShortvalue from the givenInputStreamassuming that the next value in the byte stream is that type.intStreamTypeDecoder.readSize(InputStream stream, StreamDecoderState state) Reads the size in bytes of the encoded primitive from the givenInputStreamand returns it.StreamDecoder.readString(InputStream stream, StreamDecoderState state) Reads an encodedStringvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readSymbol(InputStream stream, StreamDecoderState state) Reads an encodedSymbolvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readSymbol(InputStream stream, StreamDecoderState state, String defaultValue) Reads an encodedStringvalue from the givenInputStreamassuming 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 givenInputStreamassuming that the next value in the byte stream is that type.longStreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encoded AMQP time stamp value from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedBytevalue from the givenInputStreamassuming that the next value in the byte stream is that type.byteStreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state, byte defaultValue) Reads an encodedUnsignedBytevalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedIntegervalue from the givenInputStreamassuming that the next value in the byte stream is that type.intStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedUnsignedIntegervalue from the givenInputStreamassuming that the next value in the byte stream is that type.longStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedUnsignedIntegervalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedLongvalue from the givenInputStreamassuming that the next value in the byte stream is that type.longStreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state, long defaultValue) Reads an encodedUnsignedLongvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state) Reads an encodedUnsignedShortvalue from the givenInputStreamassuming that the next value in the byte stream is that type.intStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, int defaultValue) Reads an encodedUnsignedShortvalue from the givenInputStreamassuming that the next value in the byte stream is that type.shortStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, short defaultValue) Reads an encodedUnsignedShortvalue from the givenInputStreamassuming that the next value in the byte stream is that type.StreamDecoder.readUUID(InputStream stream, StreamDecoderState state) Reads an encodedUUIDvalue from the givenInputStreamassuming 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.voidStreamTypeDecoder.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 classState 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) booleanProtonStreamDecoder.readBoolean(InputStream stream, StreamDecoderState state, boolean defaultValue) ProtonStreamDecoder.readByte(InputStream stream, StreamDecoderState state) byteProtonStreamDecoder.readByte(InputStream stream, StreamDecoderState state, byte defaultValue) ProtonStreamDecoder.readCharacter(InputStream stream, StreamDecoderState state) charProtonStreamDecoder.readCharacter(InputStream stream, StreamDecoderState state, char defaultValue) intPrimitiveArrayTypeDecoder.readCount(InputStream stream, StreamDecoderState state) Reads the number of elements in the encoded primitive from the givenInputStreamand returns it.ProtonStreamDecoder.readDecimal128(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDecimal32(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDecimal64(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDeliveryTag(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readDouble(InputStream stream, StreamDecoderState state) doubleProtonStreamDecoder.readDouble(InputStream stream, StreamDecoderState state, double defaultValue) ProtonStreamDecoder.readFloat(InputStream stream, StreamDecoderState state) floatProtonStreamDecoder.readFloat(InputStream stream, StreamDecoderState state, float defaultValue) ProtonStreamDecoder.readInteger(InputStream stream, StreamDecoderState state) intProtonStreamDecoder.readInteger(InputStream stream, StreamDecoderState state, int defaultValue) <V> List<V>ProtonStreamDecoder.readList(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readLong(InputStream stream, StreamDecoderState state) longProtonStreamDecoder.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> TProtonStreamDecoder.readObject(InputStream stream, StreamDecoderState state, Class<T> clazz) ProtonStreamDecoder.readShort(InputStream stream, StreamDecoderState state) shortProtonStreamDecoder.readShort(InputStream stream, StreamDecoderState state, short defaultValue) intAbstractDescribedTypeDecoder.readSize(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readString(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readSymbol(InputStream stream, StreamDecoderState state) ProtonStreamDecoder.readSymbol(InputStream stream, StreamDecoderState state, String defaultValue) ProtonStreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state) longProtonStreamDecoder.readTimestamp(InputStream stream, StreamDecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state) byteProtonStreamDecoder.readUnsignedByte(InputStream stream, StreamDecoderState state, byte defaultValue) ProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state) intProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, int defaultValue) longProtonStreamDecoder.readUnsignedInteger(InputStream stream, StreamDecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state) longProtonStreamDecoder.readUnsignedLong(InputStream stream, StreamDecoderState state, long defaultValue) ProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state) intProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, int defaultValue) shortProtonStreamDecoder.readUnsignedShort(InputStream stream, StreamDecoderState state, short defaultValue) ProtonStreamDecoder.readUUID(InputStream stream, StreamDecoderState state) final DescribedTypeUnknownDescribedTypeDecoder.readValue(InputStream stream, StreamDecoderState state) protected <KeyType> voidAbstractDescribedMapTypeDecoder.scanMapEntries(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) final voidAbstractDescribedListTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) final voidAbstractDescribedMapTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) final voidUnknownDescribedTypeDecoder.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) voidDeliveryAnnotationsTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedDeliveryAnnotationsmap looking for keys that match with the providedScanningContext.voidFooterTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedFootermap looking for keys that match with the providedScanningContext.voidMessageAnnotationsTypeDecoder.scanAnnotations(InputStream stream, StreamDecoderState state, StreamScanningContext<Symbol> context, BiConsumer<Symbol, Object> matchConsumer) Scans through the encodedMessageAnnotationsmap looking for keys that match with the providedScanningContext.voidApplicationPropertiesTypeDecoder.scanProperties(InputStream stream, StreamDecoderState state, StreamScanningContext<String> context, BiConsumer<String, Object> matchConsumer) Scans through the encodedApplicationPropertiesmap looking for keys that match with the providedScanningContext.voidAmqpSequenceTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAmqpValueTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidDataTypeDecoder.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 TypeMethodDescriptionintArray32TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intArray8TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intList0TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intList32TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intList8TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intListTypeDecoder.readCount(InputStream stream, StreamDecoderState state) Reads the number of elements contained in the encoded list from the providedInputStream.intMap32TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intMap8TypeDecoder.readCount(InputStream stream, StreamDecoderState state) intMapTypeDecoder.readCount(InputStream stream, StreamDecoderState state) Reads the count of entries in the encoded Map.booleanBooleanFalseTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) booleanBooleanTrueTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) booleanBooleanTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.byteByteTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.charCharacterTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.doubleDoubleTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.floatFloatTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.intInteger32TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.intInteger8TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.longLong8TypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) longLongTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.shortShortTypeDecoder.readPrimitiveValue(InputStream stream, StreamDecoderState state) Reads the primitive value from the givenInputStreamand returns it.intArray32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intArray8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intBinary32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intBinary8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intBooleanFalseTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intBooleanTrueTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intBooleanTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intByteTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intCharacterTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intDecimal128TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intDecimal32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intDecimal64TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intDoubleTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intFloatTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intInteger32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intInteger8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intList0TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intList32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intList8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intLong8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intLongTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intMap32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intMap8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intNullTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intShortTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intString32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intString8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intSymbol32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intSymbol8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intTimestampTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedByteTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedInteger0TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedInteger32TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedInteger8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedLong0TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedLong64TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedLong8TypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUnsignedShortTypeDecoder.readSize(InputStream stream, StreamDecoderState state) intUUIDTypeDecoder.readSize(InputStream stream, StreamDecoderState state) AbstractSymbolTypeDecoder.readString(InputStream stream, StreamDecoderState state) Reads a String view of an encoded Symbol value from the given buffer.AbstractArrayTypeDecoder.readValue(InputStream stream, StreamDecoderState state) AbstractBinaryTypeDecoder.readValue(InputStream stream, StreamDecoderState state) AbstractListTypeDecoder.readValue(InputStream stream, StreamDecoderState state) AbstractMapTypeDecoder.readValue(InputStream stream, StreamDecoderState state) AbstractStringTypeDecoder.readValue(InputStream stream, StreamDecoderState state) AbstractSymbolTypeDecoder.readValue(InputStream stream, StreamDecoderState state) BooleanFalseTypeDecoder.readValue(InputStream stream, StreamDecoderState state) BooleanTrueTypeDecoder.readValue(InputStream stream, StreamDecoderState state) BooleanTypeDecoder.readValue(InputStream stream, StreamDecoderState state) ByteTypeDecoder.readValue(InputStream stream, StreamDecoderState state) CharacterTypeDecoder.readValue(InputStream stream, StreamDecoderState state) Decimal128TypeDecoder.readValue(InputStream stream, StreamDecoderState state) Decimal32TypeDecoder.readValue(InputStream stream, StreamDecoderState state) Decimal64TypeDecoder.readValue(InputStream stream, StreamDecoderState state) DoubleTypeDecoder.readValue(InputStream stream, StreamDecoderState state) FloatTypeDecoder.readValue(InputStream stream, StreamDecoderState state) Integer32TypeDecoder.readValue(InputStream stream, StreamDecoderState state) Integer8TypeDecoder.readValue(InputStream stream, StreamDecoderState state) List0TypeDecoder.readValue(InputStream stream, StreamDecoderState state) Long8TypeDecoder.readValue(InputStream stream, StreamDecoderState state) LongTypeDecoder.readValue(InputStream stream, StreamDecoderState state) NullTypeDecoder.readValue(InputStream stream, StreamDecoderState state) ShortTypeDecoder.readValue(InputStream stream, StreamDecoderState state) TimestampTypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedByteTypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedInteger0TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedInteger32TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedInteger8TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedLong0TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedLong64TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedLong8TypeDecoder.readValue(InputStream stream, StreamDecoderState state) UnsignedShortTypeDecoder.readValue(InputStream stream, StreamDecoderState state) UUIDTypeDecoder.readValue(InputStream stream, StreamDecoderState state) byte[]AbstractBinaryTypeDecoder.readValueAsArray(InputStream stream, StreamDecoderState state) Read and decode an AMQPBinaryinto a byte array instance and return it.AbstractBinaryTypeDecoder.readValueAsBuffer(InputStream stream, StreamDecoderState state) Read and decode an AMQPBinaryinto aProtonBufferinstance and return it.<KeyType> voidAbstractMapTypeDecoder.scanKeys(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) <KeyType> voidMapTypeDecoder.scanKeys(InputStream stream, StreamDecoderState state, StreamScanningContext<KeyType> context, BiConsumer<KeyType, Object> matchConsumer) Scan the encodedMapkeys 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.voidAbstractArrayTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAbstractBinaryTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAbstractListTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAbstractMapTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAbstractStringTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidAbstractSymbolTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidBooleanFalseTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidBooleanTrueTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidBooleanTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidByteTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidCharacterTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidDecimal128TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidDecimal32TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidDecimal64TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidDoubleTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidFloatTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidInteger32TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidInteger8TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidList0TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidLong8TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidLongTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidNullTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidShortTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidTimestampTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedByteTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedInteger0TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedInteger32TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedInteger8TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedLong0TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedLong64TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedLong8TypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUnsignedShortTypeDecoder.skipValue(InputStream stream, StreamDecoderState state) voidUUIDTypeDecoder.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) -
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) -
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)