Module org.apache.qpid.protonj2

Package org.apache.qpid.protonj2.codec.decoders.messaging

Class ApplicationPropertiesTypeDecoder

java.lang.Object

org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder<ApplicationProperties>

org.apache.qpid.protonj2.codec.decoders.AbstractDescribedMapTypeDecoder<ApplicationProperties,String>

org.apache.qpid.protonj2.codec.decoders.messaging.ApplicationPropertiesTypeDecoder

All Implemented Interfaces:

DescribedTypeDecoder<ApplicationProperties>, StreamDescribedTypeDecoder<ApplicationProperties>, StreamTypeDecoder<ApplicationProperties>, TypeDecoder<ApplicationProperties>

public final class ApplicationPropertiesTypeDecoder
extends AbstractDescribedMapTypeDecoder<ApplicationProperties,String>

Decoder of AMQP ApplicationProperties types from a byte stream

Field Summary

Fields

Modifier and Type	Field	Description
static final ApplicationPropertiesTypeDecoder	INSTANCE

Constructor Summary

Constructors

Constructor	Description
ApplicationPropertiesTypeDecoder()

Method Summary

Modifier and Type	Method	Description
protected ApplicationProperties	createDescribed(Map<String,Object> map)	Called from read method to wrap the decoded Map in the described type wrapper that this Map type manages.
static ScanningContext<String>	createScanContext(String... keys)	Creates a new scanning context for the given collection of String values.
static ScanningContext<String>	createScanContext(Collection<String> keys)	Creates a new scanning context for the given collection of String values.
static StreamScanningContext<String>	createStreamScanContext(String... keys)	Creates a new scanning context for the given collection of String values.
static StreamScanningContext<String>	createStreamScanContext(Collection<String> keys)	Creates a new scanning context for the given collection of String values.
UnsignedLong	getDescriptorCode()	Returns the AMQP descriptor code for the type this decoder reads.
Symbol	getDescriptorSymbol()	Returns the AMQP descriptor symbol for the type this decoder reads.
Class<ApplicationProperties>	getTypeClass()	Returns the Class that this decoder handles.
protected String	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.
protected String	readKey(ProtonBuffer buffer, Decoder decoder, DecoderState 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.
void	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	scanProperties(ProtonBuffer buffer, DecoderState state, ScanningContext<String> context, BiConsumer<String,Object> matchConsumer)	Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext.

Methods inherited from class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedMapTypeDecoder

readArrayElements, readArrayElements, readValue, readValue, scanMapEntries, scanMapEntries, skipValue, skipValue, validateAndGetCount, validateAndGetCount

Methods inherited from class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder

checkIsExpectedType, checkIsExpectedType, checkIsExpectedTypeAndCast, checkIsExpectedTypeAndCast, isArrayType, isNull, isPrimitive, readSize, readSize, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.protonj2.codec.DescribedTypeDecoder

decoderRegistered

Field Details

INSTANCE

public static final ApplicationPropertiesTypeDecoder INSTANCE

Constructor Details

ApplicationPropertiesTypeDecoder

public ApplicationPropertiesTypeDecoder()

Method Details

getTypeClass

public Class<ApplicationProperties> getTypeClass()

Description copied from interface: TypeDecoder

Returns the Class that this decoder handles.

Returns:

the Class that this decoder handles

getDescriptorCode

public UnsignedLong getDescriptorCode()

Description copied from interface: DescribedTypeDecoder

Returns the AMQP descriptor code for the type this decoder reads.

Returns:

an unsigned long descriptor code value.

getDescriptorSymbol

public Symbol getDescriptorSymbol()

Description copied from interface: DescribedTypeDecoder

Returns the AMQP descriptor symbol for the type this decoder reads.

Returns:

an symbol descriptor code value.

readKey

protected String readKey(ProtonBuffer buffer,
 Decoder decoder,
 DecoderState state)
                  throws DecodeException

Description copied from class: AbstractDescribedMapTypeDecoder

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.

Specified by:

readKey in class AbstractDescribedMapTypeDecoder<ApplicationProperties,String>

Parameters:

buffer - The buffer where the encoded Map body lives.

decoder - The Decoder to use for reading the key.

state - The DecoderState to use while reading the key.

Returns:

the newly read Map key.

Throws:

DecodeException - if an error occurs while reading the map key.

readKey

protected String readKey(InputStream stream,
 StreamDecoder decoder,
 StreamDecoderState state)
                  throws DecodeException

Description copied from class: AbstractDescribedMapTypeDecoder

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.

Specified by:

readKey in class AbstractDescribedMapTypeDecoder<ApplicationProperties,String>

Parameters:

stream - The bytes stream where the encoded Map body lives.

decoder - The Decoder to use for reading the key.

state - The DecoderState to use while reading the key.

Returns:

the newly read Map key.

Throws:

DecodeException - if an error occurs while reading the map key.

createDescribed

protected ApplicationProperties createDescribed(Map<String,Object> map)

Description copied from class: AbstractDescribedMapTypeDecoder

Called from read method to wrap the decoded Map in the described type wrapper that this Map type manages.

Specified by:

createDescribed in class AbstractDescribedMapTypeDecoder<ApplicationProperties,String>

Parameters:

map - The decoded map that this type handles.

Returns:

the described type wrapper around the decoded Map.

createScanContext

public static ScanningContext<String> createScanContext(String... keys)

Creates a new scanning context for the given collection of String values.

Parameters:

keys - The String keys that will be scanned for in the encoded Map

Returns:

a ScanningContext for the collection of string keys.

createScanContext

public static ScanningContext<String> createScanContext(Collection<String> keys)

Creates a new scanning context for the given collection of String values.

Parameters:

keys - The String keys that will be scanned for in the encoded Map

Returns:

a ScanningContext for the collection of string keys.

createStreamScanContext

public static StreamScanningContext<String> createStreamScanContext(String... keys)

Creates a new scanning context for the given collection of String values.

Parameters:

keys - The String keys that will be scanned for in the encoded Map

Returns:

a ScanningContext for the collection of string keys.

createStreamScanContext

public static StreamScanningContext<String> createStreamScanContext(Collection<String> keys)

Creates a new scanning context for the given collection of String values.

Parameters:

keys - The String keys that will be scanned for in the encoded Map

Returns:

a ScanningContext for the collection of string keys.

scanProperties

public void scanProperties(ProtonBuffer buffer,
 DecoderState state,
 ScanningContext<String> context,
 BiConsumer<String,Object> matchConsumer)
                    throws DecodeException

Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext. When a match is found the provided match consumer is called with the matched key and the decoded value mapped to that key. When the method returns the caller can assume that all bytes of the encoded ApplicationProperties have been read and that decoding of the next object can begin if the provided buffer remains readable.

Parameters:

buffer - The buffer to scan for specific key / value mappings

state - The decoder state used during the scanning

context - A matching context primed with the match data needed to match encoded keys.

matchConsumer - A BiConsumer that will be notified of each matching key / value pair.

Throws:

DecodeException - if an error is encountered while reading the next value.

scanProperties

public void scanProperties(InputStream stream,
 StreamDecoderState state,
 StreamScanningContext<String> context,
 BiConsumer<String,Object> matchConsumer)
                    throws DecodeException

Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext. When a match is found the provided match consumer is called with the matched key and the decoded value mapped to that key. When the method returns the caller can assume that all bytes of the encoded ApplicationProperties have been read and that decoding of the next object can begin if the provided stream remains readable.

Parameters:

stream - The InputStream to scan for specific key / value mappings

state - The decoder state used during the scanning

context - A matching context primed with the match data needed to match encoded keys.

matchConsumer - A BiConsumer that will be notified of each matching key / value pair.

Throws:

DecodeException - if an error is encountered while reading the next value.