AmqpMessageImpl

accepted AmqpMessage accepted(): Undocumented in source. Be warned that the author may not have intended to support it.
address string address(): Undocumented in source. Be warned that the author may not have intended to support it.
applicationProperties ApplicationProperties applicationProperties(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsBinary byte[] bodyAsBinary(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsBoolean bool bodyAsBoolean(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsByte byte bodyAsByte(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsChar char bodyAsChar(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsDouble double bodyAsDouble(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsFloat float bodyAsFloat(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsInteger int bodyAsInteger(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsList List!Object bodyAsList(): @noinspection unchecked
bodyAsLong long bodyAsLong(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsShort short bodyAsShort(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsString string bodyAsString(): Undocumented in source. Be warned that the author may not have intended to support it.
bodyAsSymbol string bodyAsSymbol(): Undocumented in source. Be warned that the author may not have intended to support it.
contentEncoding string contentEncoding(): Undocumented in source. Be warned that the author may not have intended to support it.
contentType string contentType(): Undocumented in source. Be warned that the author may not have intended to support it.
correlationId string correlationId(): Undocumented in source. Be warned that the author may not have intended to support it.
creationTime long creationTime(): Undocumented in source. Be warned that the author may not have intended to support it.
deliveryCount int deliveryCount(): Undocumented in source. Be warned that the author may not have intended to support it.
expiryTime long expiryTime(): Undocumented in source. Be warned that the author may not have intended to support it.
groupId string groupId(): Undocumented in source. Be warned that the author may not have intended to support it.
groupSequence long groupSequence(): Undocumented in source. Be warned that the author may not have intended to support it.
id string id(): Undocumented in source. Be warned that the author may not have intended to support it.
isBodyNull bool isBodyNull(): Undocumented in source. Be warned that the author may not have intended to support it.
isDurable bool isDurable(): Undocumented in source. Be warned that the author may not have intended to support it.
isFirstAcquirer bool isFirstAcquirer(): Undocumented in source. Be warned that the author may not have intended to support it.
modified AmqpMessage modified(bool didItFail, bool wasItDeliveredHere): Undocumented in source. Be warned that the author may not have intended to support it.
priority int priority(): Undocumented in source. Be warned that the author may not have intended to support it.
rejected AmqpMessage rejected(): Undocumented in source. Be warned that the author may not have intended to support it.
released AmqpMessage released(): Undocumented in source. Be warned that the author may not have intended to support it.
replyTo string replyTo(): Undocumented in source. Be warned that the author may not have intended to support it.
replyToGroupId string replyToGroupId(): Undocumented in source. Be warned that the author may not have intended to support it.
subject string subject(): @noinspection unchecked
ttl long ttl(): Undocumented in source. Be warned that the author may not have intended to support it.
unwrap Message unwrap(): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From AmqpMessage

create AmqpMessageBuilder create(): @return a builder to create an {@link AmqpMessage}.
create AmqpMessageBuilder create(AmqpMessage existing): Creates a builder to create a new {@link AmqpMessage} copying the metadata from the passed message.
create AmqpMessageBuilder create(Message existing): Creates a builder to create a new {@link AmqpMessage} copying the metadata from the passed (Proton) message.
isDurable bool isDurable(): @return whether or not the message is durable. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header">AMQP specification</a>
isFirstAcquirer bool isFirstAcquirer(): @return if {@code true}, then this message has not been acquired by any other link. If {@code false}, then this message MAY have previously been acquired by another link or links. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header">AMQP specification</a>
priority int priority(): @return the relative message priority. Higher numbers indicate higher priority messages. Messages with higher priorities MAY be delivered before those with lower priorities. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header">AMQP specification</a>
deliveryCount int deliveryCount(): @return the number of unsuccessful previous attempts to deliver this message. If this value is non-zero it can be taken as an indication that the delivery might be a duplicate. On first delivery, the value is zero. It is incremented upon an outcome being settled at the sender, according to rules defined for each outcome. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header">AMQP specification</a>
ttl long ttl(): @return the duration in milliseconds for which the message is to be considered "live". @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties">AMQP specification</a>
id string id(): @return the message id @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties">AMQP specification</a>
address string address(): @return the message address, also named {@code to} field @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties">AMQP specification</a>
replyTo string replyTo(): @return The address of the node to send replies to, if any. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties">AMQP specification</a>
correlationId string correlationId(): @return The client-specific id that can be used to mark or identify messages between clients. @see <a href="http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties">AMQP specification</a>
isBodyNull bool isBodyNull(): @return whether the body is {@code null}. This method returns {@code true} is the message does not contain a body or if the message contain a {@code null} AMQP value as body.
bodyAsBoolean bool bodyAsBoolean(): @return the boolean value contained in the body. The value must be passed as AMQP value.
bodyAsByte byte bodyAsByte(): @return the byte value contained in the body. The value must be passed as AMQP value.
bodyAsShort short bodyAsShort(): @return the short value contained in the body. The value must be passed as AMQP value.
bodyAsInteger int bodyAsInteger(): @return the integer value contained in the body. The value must be passed as AMQP value.
bodyAsLong long bodyAsLong(): @return the long value contained in the body. The value must be passed as AMQP value.
bodyAsFloat float bodyAsFloat(): @return the float value contained in the body. The value must be passed as AMQP value.
bodyAsDouble double bodyAsDouble(): @return the double value contained in the body. The value must be passed as AMQP value.
bodyAsChar char bodyAsChar(): @return the character value contained in the body. The value must be passed as AMQP value.
bodyAsBinary byte[] bodyAsBinary(): @return the bytes contained in the body. The value must be passed as AMQP data.
bodyAsString string bodyAsString(): @return the string value contained in the body. The value must be passed as AMQP value.
bodyAsSymbol string bodyAsSymbol(): @return the symbol value contained in the body. The value must be passed as AMQP value.
bodyAsList List!Object bodyAsList(): @return the list of values contained in the body. The value must be passed as AMQP value.
subject string subject(): @return the JSON array contained in the body. The value must be passed as AMQP data.
contentType string contentType(): Undocumented in source.
contentEncoding string contentEncoding(): Undocumented in source.
expiryTime long expiryTime(): Undocumented in source.
creationTime long creationTime(): Undocumented in source.
groupId string groupId(): Undocumented in source.
replyToGroupId string replyToGroupId(): Undocumented in source.
groupSequence long groupSequence(): Undocumented in source.
unwrap Message unwrap(): @return the message properties as JSON object.
accepted AmqpMessage accepted(): When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message. It marks the message as delivered with the {@code accepted} status.
rejected AmqpMessage rejected(): When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as {@code rejected}.
released AmqpMessage released(): When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as {@code released}.
modified AmqpMessage modified(bool didItFail, bool wasItDeliveredHere): When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as {@code modified}.

AmqpMessageImpl

Constructors

Members

Functions

Inherited Members

From AmqpMessage

Meta

Source