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.