Uses of Interface
org.apache.qpid.protonj2.client.Message

Packages that use Message

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

Uses of Message in org.apache.qpid.protonj2.client

Subinterfaces of Message in org.apache.qpid.protonj2.client

Modifier and Type	Interface	Description
interface	AdvancedMessage<E>	Advanced AMQP Message object that provides a thin abstraction to raw AMQP types
interface	StreamReceiverMessage	A specialized Message type that represents a streamed delivery possibly spanning many incoming Transfer frames from the remote peer.
interface	StreamSenderMessage	Streaming Message Tracker object used to operate on and track the state of a streamed message at the remote.

Methods in org.apache.qpid.protonj2.client that return Message

Modifier and Type	Method	Description
Message<E>	Message.absoluteExpiryTime(long expiryTime)	Sets the absolute expiration time value to assign to this Message.
Message<E>	Message.annotation(String key, Object value)	Sets the given message annotation value at the given key, replacing any previous value that was assigned to this Message.
Message<E>	Message.body(E value)	Sets the body value that is to be conveyed to the remote when this message is sent.
Message<?>	Message.contentEncoding(String contentEncoding)	Sets the contentEncoding value to assign to this Message.
Message<E>	Message.contentType(String contentType)	Sets the contentType value to assign to this Message.
Message<E>	Message.correlationId(Object correlationId)	Sets the correlationId value to assign to this Message.
static <E> Message<E>	Message.create()	Create and return an Message that will carry no body Section unless one is assigned by the caller.
static Message<byte[]>	Message.create(byte[] body)	Create and return an Message that will wrap the given byte array in an Data section.
static <E> Message<E>	Message.create(E body)	Create and return an Message that will wrap the given Object in an AmqpValue section.
static <E> Message<List<E>>	Message.create(List<E> body)	Create and return an Message that will wrap the given List in an AmqpSequence section.
static <K, V> Message<Map<K,V>>	Message.create(Map<K,V> body)	Create and return an Message that will wrap the given Map in an AmqpValue section.
Message<E>	Message.creationTime(long createTime)	Sets the creation time value to assign to this Message.
Message<E>	Message.deliveryCount(long deliveryCount)	Sets the value to assign to the delivery count field of this Message.
Message<E>	Message.durable(boolean durable)	Controls if the message is marked as durable when sent.
Message<E>	Message.firstAcquirer(boolean firstAcquirer)	Sets the value to assign to the first acquirer field of this Message.
Message<E>	Message.footer(String key, Object value)	Sets the given footer value at the given key, replacing any previous value that was assigned to this Message.
Message<E>	Message.forEachAnnotation(BiConsumer<String,Object> action)	Invokes the given BiConsumer on each message annotation entry carried in this Message.
Message<E>	Message.forEachFooter(BiConsumer<String,Object> action)	Invokes the given BiConsumer on each footer entry carried in this Message.
Message<E>	Message.forEachProperty(BiConsumer<String,Object> action)	Invokes the given BiConsumer on each application property entry carried in this Message.
Message<E>	Message.groupId(String groupId)	Sets the groupId value to assign to this Message.
Message<E>	Message.groupSequence(int groupSequence)	Sets the group sequence value to assign to this Message.
<E> Message<E>	Delivery.message()	Decode the Delivery payload and return an Message object.
Message<E>	Message.messageId(Object messageId)	Sets the message Id value to assign to this Message.
Message<E>	Message.priority(byte priority)	Sets the relative message priority.
Message<E>	Message.property(String key, Object value)	Sets the given application property value at the given key, replacing any previous value that was assigned to this Message.
Message<E>	Message.replyTo(String replyTo)	Sets the replyTo value to assign to this Message.
Message<E>	Message.replyToGroupId(String replyToGroupId)	Sets the replyTo group Id value to assign to this Message.
Message<E>	Message.subject(String subject)	Sets the subject value to assign to this Message.
Message<E>	Message.timeToLive(long timeToLive)	Sets the message time to live value.
Message<E>	Message.to(String to)	Sets the 'to' value to assign to this Message.
Message<E>	Message.userId(byte[] userId)	Sets the user Id value to assign to this Message.

Methods in org.apache.qpid.protonj2.client with parameters of type Message

Modifier and Type	Method	Description
Tracker	Connection.send(Message<?> message)	Sends the given Message using the internal connection sender.
Tracker	Sender.send(Message<?> message)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.
Tracker	Sender.send(Message<?> message, Map<String,Object> deliveryAnnotations)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.
StreamTracker	StreamSender.send(Message<?> message)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit or there is a streaming send ongoing.
StreamTracker	StreamSender.send(Message<?> message, Map<String,Object> deliveryAnnotations)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit or there is a streaming send ongoing.
Tracker	Sender.trySend(Message<?> message)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.
Tracker	Sender.trySend(Message<?> message, Map<String,Object> deliveryAnnotations)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.
StreamTracker	StreamSender.trySend(Message<?> message)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt or a streaming send is ongoing.
StreamTracker	StreamSender.trySend(Message<?> message, Map<String,Object> deliveryAnnotations)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.

Uses of Message in org.apache.qpid.protonj2.client.impl

Classes in org.apache.qpid.protonj2.client.impl that implement Message

Modifier and Type	Class	Description
final class	ClientMessage<E>	Client provided AdvancedMessage implementation that is used when sending messages from a ClientSender or when decoding an AMQP Transfer for which all frames have arrived.
final class	ClientStreamReceiverMessage	Streamed message delivery context used to request reads of possible split framed Transfer payload's that comprise a single large overall message.

Methods in org.apache.qpid.protonj2.client.impl that return Message

Modifier and Type	Method	Description
Message<E>	ClientMessage.absoluteExpiryTime(long expiryTime)
Message<E>	ClientMessage.contentEncoding(String contentEncoding)
Message<?>	ClientStreamReceiverMessage.contentEncoding(String contentEncoding)
Message<E>	ClientMessage.contentType(String contentType)
Message<E>	ClientMessage.correlationId(Object correlationId)
Message<E>	ClientMessage.creationTime(long createTime)
static Message<?>	ClientMessageSupport.decodeMessage(ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, DecoderState decoderState, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
Message<E>	ClientMessage.forEachAnnotation(BiConsumer<String,Object> action)
Message<E>	ClientMessage.forEachFooter(BiConsumer<String,Object> action)
Message<E>	ClientMessage.forEachProperty(BiConsumer<String,Object> action)
Message<E>	ClientMessage.groupId(String groupId)
Message<E>	ClientMessage.groupSequence(int groupSequence)
<E> Message<E>	ClientDelivery.message()
Message<E>	ClientMessage.messageId(Object messageId)
Message<E>	ClientMessage.replyTo(String replyTo)
Message<E>	ClientMessage.replyToGroupId(String replyToGroupId)
Message<E>	ClientMessage.subject(String subject)
Message<E>	ClientMessage.to(String to)
Message<E>	ClientMessage.userId(byte[] userId)

Methods in org.apache.qpid.protonj2.client.impl with parameters of type Message

Modifier and Type	Method	Description
static <E> AdvancedMessage<E>	ClientMessageSupport.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.
Tracker	ClientConnection.send(Message<?> message)
Tracker	ClientSender.send(Message<?> message)
Tracker	ClientSender.send(Message<?> message, Map<String,Object> deliveryAnnotations)
StreamTracker	ClientStreamSender.send(Message<?> message)
StreamTracker	ClientStreamSender.send(Message<?> message, Map<String,Object> deliveryAnnotations)
Tracker	ClientSender.trySend(Message<?> message)
Tracker	ClientSender.trySend(Message<?> message, Map<String,Object> deliveryAnnotations)
StreamTracker	ClientStreamSender.trySend(Message<?> message)
StreamTracker	ClientStreamSender.trySend(Message<?> message, Map<String,Object> deliveryAnnotations)