Uses of Interface
org.apache.qpid.protonj2.client.AdvancedMessage
-
Uses of AdvancedMessage in org.apache.qpid.protonj2.client
Modifier and TypeInterfaceDescriptioninterface
interface
Streaming Message Tracker object used to operate on and track the state of a streamed message at the remote.Modifier and TypeMethodDescriptionAdvancedMessage.addBodySection
(Section<?> bodySection) Adds the givenSection
to the internal collection of sections that will be sent to the remote peer when this message is encoded.AdvancedMessage.annotations
(MessageAnnotations messageAnnotations) Assign or replace theMessageAnnotations
instance associated with this message.AdvancedMessage.applicationProperties
(ApplicationProperties applicationProperties) Assign or replace theApplicationProperties
instance associated with this message.AdvancedMessage.bodySections
(Collection<Section<?>> sections) Sets the bodySection
instances to use when encoding this message.AdvancedMessage.clearBodySections()
Clears all current bodySection
elements from theAdvancedMessage
.static <V> AdvancedMessage<V>
AdvancedMessage.create()
Creates a newAdvancedMessage
instance using the library default implementation.Assign or replace theFooter
instance associated with this message.AdvancedMessage.forEachBodySection
(Consumer<Section<?>> consumer) Performs the given action for each bodySection
of theAdvancedMessage
until all sections have been presented to the givenConsumer
or the consumer throws an exception.Assign or replace theHeader
instance associated with this message.AdvancedMessage.messageFormat
(int messageFormat) Sets the message format to use when the message is sent.AdvancedMessage.properties
(Properties properties) Assign or replace theProperties
instance associated with this message.default AdvancedMessage<E>
Message.toAdvancedMessage()
Safely convert thisMessage
instance into anAdvancedMessage
reference which can offer more low level APIs to an experienced client user. -
Uses of AdvancedMessage in org.apache.qpid.protonj2.client.impl
Modifier and TypeClassDescriptionfinal class
Client providedAdvancedMessage
implementation that is used when sending messages from aClientSender
or when decoding an AMQP Transfer for which all frames have arrived.final class
Streamed message delivery context used to request reads of possible split framedTransfer
payload's that comprise a single large overall message.Modifier and TypeMethodDescriptionstatic <E> AdvancedMessage<E>
ClientMessageSupport.convertMessage
(Message<E> message) Converts aMessage
instance into aClientMessage
instance either by cast or by construction of a new instance with a copy of the values carried in the given message.ClientMessage.toAdvancedMessage()
Modifier and TypeMethodDescriptionstatic ProtonBuffer
ClientMessageSupport.encodeMessage
(AdvancedMessage<?> message, Map<String, Object> deliveryAnnotations) static ProtonBuffer
ClientMessageSupport.encodeMessage
(AdvancedMessage<?> message, Map<String, Object> deliveryAnnotations, ProtonBufferAllocator allocator) static ProtonBuffer
ClientMessageSupport.encodeMessage
(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String, Object> deliveryAnnotations) static ProtonBuffer
ClientMessageSupport.encodeMessage
(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String, Object> deliveryAnnotations)