public interface AmqpMessage
Reference about the different metadata can be found on AMQP message properties.
Note that the body is retrieved using body* method depending on the expected type.
static AmqpMessageBuilder create()
AmqpMessage.static AmqpMessageBuilder create(AmqpMessage existing)
AmqpMessage copying the metadata from the passed message.existing - an existing message, must not be null.AmqpMessage.static AmqpMessageBuilder create(org.apache.qpid.proton.message.Message existing)
AmqpMessage copying the metadata from the passed (Proton) message.existing - an existing (Proton) message, must not be null.AmqpMessage.boolean isDurable()
boolean isFirstAcquirer()
true, then this message has not been acquired by any other link. If false, then this
message MAY have previously been acquired by another link or links.int priority()
int deliveryCount()
long ttl()
String id()
String address()
to fieldString replyTo()
String correlationId()
boolean isBodyNull()
null. This method returns true is the message does not contain a body or
if the message contain a null AMQP value as body.boolean bodyAsBoolean()
byte bodyAsByte()
short bodyAsShort()
int bodyAsInteger()
long bodyAsLong()
float bodyAsFloat()
double bodyAsDouble()
char bodyAsChar()
java.time.Instant bodyAsTimestamp()
UUID bodyAsUUID()
Buffer bodyAsBinary()
String bodyAsString()
String bodyAsSymbol()
<T> List<T> bodyAsList()
<K,V> Map<K,V> bodyAsMap()
JsonObject bodyAsJsonObject()
JsonArray bodyAsJsonArray()
String subject()
String contentType()
String contentEncoding()
long expiryTime()
long creationTime()
String groupId()
String replyToGroupId()
long groupSequence()
JsonObject applicationProperties()
org.apache.qpid.proton.message.Message unwrap()
Copyright © 2019 Eclipse. All rights reserved.