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.
Modifier and Type | Method and Description |
---|---|
AmqpMessage |
accepted()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message.
|
String |
address() |
JsonObject |
applicationProperties() |
Buffer |
bodyAsBinary() |
boolean |
bodyAsBoolean() |
byte |
bodyAsByte() |
char |
bodyAsChar() |
double |
bodyAsDouble() |
float |
bodyAsFloat() |
int |
bodyAsInteger() |
JsonArray |
bodyAsJsonArray() |
JsonObject |
bodyAsJsonObject() |
<T> List<T> |
bodyAsList() |
long |
bodyAsLong() |
<K,V> Map<K,V> |
bodyAsMap() |
short |
bodyAsShort() |
String |
bodyAsString() |
String |
bodyAsSymbol() |
java.time.Instant |
bodyAsTimestamp() |
UUID |
bodyAsUUID() |
String |
contentEncoding() |
String |
contentType() |
String |
correlationId() |
static AmqpMessageBuilder |
create() |
static AmqpMessageBuilder |
create(AmqpMessage existing)
Creates a builder to create a new
AmqpMessage copying the metadata from the passed message. |
static AmqpMessageBuilder |
create(org.apache.qpid.proton.message.Message existing)
Creates a builder to create a new
AmqpMessage copying the metadata from the passed (Proton) message. |
long |
creationTime() |
int |
deliveryCount() |
long |
expiryTime() |
String |
groupId() |
long |
groupSequence() |
String |
id() |
boolean |
isBodyNull() |
boolean |
isDurable() |
boolean |
isFirstAcquirer() |
AmqpMessage |
modified(boolean deliveryFailed,
boolean undeliverableHere)
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
modified . |
int |
priority() |
AmqpMessage |
rejected()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
rejected . |
AmqpMessage |
released()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
released . |
String |
replyTo() |
String |
replyToGroupId() |
String |
subject() |
long |
ttl() |
org.apache.qpid.proton.message.Message |
unwrap() |
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()
AmqpMessage accepted()
accepted
status.AmqpMessage
objectIllegalStateException
- is the current message is not a received message.AmqpMessage rejected()
rejected
.AmqpMessage
objectIllegalStateException
- is the current message is not a received message.AmqpMessage released()
released
.AmqpMessage
objectIllegalStateException
- is the current message is not a received message.AmqpMessage modified(boolean deliveryFailed, boolean undeliverableHere)
modified
.deliveryFailed
- pass true
to increase the failed delivery countundeliverableHere
- pass true
to prevent re-delivery of this message to the same consumerAmqpMessage
objectIllegalStateException
- is the current message is not a received message.Copyright © 2021 Eclipse. All rights reserved.