Uses of Interface
org.apache.qpid.protonj2.client.AdvancedMessage
-
Packages that use AdvancedMessage Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of AdvancedMessage in org.apache.qpid.protonj2.client
Subinterfaces of AdvancedMessage in org.apache.qpid.protonj2.client Modifier and Type Interface Description interface
StreamReceiverMessage
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 AdvancedMessage Modifier and Type Method Description AdvancedMessage<E>
AdvancedMessage. 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<E>
AdvancedMessage. annotations(MessageAnnotations messageAnnotations)
Assign or replace theMessageAnnotations
instance associated with this message.AdvancedMessage<E>
AdvancedMessage. applicationProperties(ApplicationProperties applicationProperties)
Assign or replace theApplicationProperties
instance associated with this message.AdvancedMessage<E>
AdvancedMessage. bodySections(java.util.Collection<Section<?>> sections)
Sets the bodySection
instances to use when encoding this message.AdvancedMessage<E>
AdvancedMessage. clearBodySections()
Clears all current bodySection
elements from theAdvancedMessage
.static <V> AdvancedMessage<V>
AdvancedMessage. create()
Creates a newAdvancedMessage
instance using the library default implementation.AdvancedMessage<E>
AdvancedMessage. footer(Footer footer)
Assign or replace theFooter
instance associated with this message.AdvancedMessage<E>
AdvancedMessage. forEachBodySection(java.util.function.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.AdvancedMessage<E>
AdvancedMessage. header(Header header)
Assign or replace theHeader
instance associated with this message.AdvancedMessage<E>
AdvancedMessage. messageFormat(int messageFormat)
Sets the message format to use when the message is sent.AdvancedMessage<E>
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
Classes in org.apache.qpid.protonj2.client.impl that implement AdvancedMessage Modifier and Type Class Description class
ClientMessage<E>
Client providedAdvancedMessage
implementation that is used when sending messages from aClientSender
or when decoding an AMQP Transfer for which all frames have arrived.class
ClientStreamReceiverMessage
Streamed message delivery context used to request reads of possible split framedTransfer
payload's that comprise a single large overall message.Methods in org.apache.qpid.protonj2.client.impl that return AdvancedMessage Modifier and Type Method Description static <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.AdvancedMessage<E>
ClientMessage. toAdvancedMessage()
Methods in org.apache.qpid.protonj2.client.impl with parameters of type AdvancedMessage Modifier and Type Method Description static ProtonBuffer
ClientMessageSupport. encodeMessage(AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
-