Package org.apache.qpid.protonj2.client.impl

Class ClientMessageSupport

java.lang.Object

org.apache.qpid.protonj2.client.impl.ClientMessageSupport

public abstract class ClientMessageSupport
extends Object

Support methods dealing with Message types and encode or decode operations.

Constructor Summary

Constructors

Constructor	Description
ClientMessageSupport()

Method Summary

Modifier and Type	Method	Description
static <E> AdvancedMessage<E>	convertMessage(Message<E> message)	Converts a Message instance into a ClientMessage instance either by cast or by construction of a new instance with a copy of the values carried in the given message.
static <E> Section<E>	createSectionFromValue(E body)
static Message<?>	decodeMessage(ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	decodeMessage(Decoder decoder, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	decodeMessage(Decoder decoder, DecoderState decoderState, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static ProtonBuffer	encodeMessage(AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	encodeMessage(AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations, ProtonBufferAllocator allocator)
static ProtonBuffer	encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	encodeSection(Section<?> section, ProtonBuffer buffer)

Methods inherited from class java.lang.Object

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

Constructor Details

ClientMessageSupport

public ClientMessageSupport()

Method Details

convertMessage

public static <E> AdvancedMessage<E> convertMessage(Message<E> message)
                                             throws ClientException

Converts a Message instance into a ClientMessage instance either by cast or by construction of a new instance with a copy of the values carried in the given message.

Type Parameters:

E - the body type of the given message.

Parameters:

message - The Message type to attempt to convert to a ClientMessage instance.

Returns:

a ClientMessage that represents the given Message instance.

Throws:

ClientException - if an unrecoverable error occurs during message conversion.

encodeSection

public static ProtonBuffer encodeSection(Section<?> section,
 ProtonBuffer buffer)

encodeMessage

public static ProtonBuffer encodeMessage(AdvancedMessage<?> message,
 Map<String,Object> deliveryAnnotations)
                                  throws ClientException

Throws:

ClientException

encodeMessage

public static ProtonBuffer encodeMessage(AdvancedMessage<?> message,
 Map<String,Object> deliveryAnnotations,
 ProtonBufferAllocator allocator)
                                  throws ClientException

Throws:

ClientException

encodeMessage

public static ProtonBuffer encodeMessage(Encoder encoder,
 ProtonBufferAllocator allocator,
 AdvancedMessage<?> message,
 Map<String,Object> deliveryAnnotations)
                                  throws ClientException

Throws:

ClientException

encodeMessage

public static ProtonBuffer encodeMessage(Encoder encoder,
 EncoderState encoderState,
 ProtonBufferAllocator allocator,
 AdvancedMessage<?> message,
 Map<String,Object> deliveryAnnotations)
                                  throws ClientException

Throws:

ClientException

decodeMessage

public static Message<?> decodeMessage(ProtonBuffer buffer,
 Consumer<DeliveryAnnotations> daConsumer)
                                throws ClientException

Throws:

ClientException

decodeMessage

public static Message<?> decodeMessage(Decoder decoder,
 ProtonBuffer buffer,
 Consumer<DeliveryAnnotations> daConsumer)
                                throws ClientException

Throws:

ClientException

decodeMessage

public static Message<?> decodeMessage(Decoder decoder,
 DecoderState decoderState,
 ProtonBuffer buffer,
 Consumer<DeliveryAnnotations> daConsumer)
                                throws ClientException

Throws:

ClientException

createSectionFromValue

public static <E> Section<E> createSectionFromValue(E body)