public class AmqpMessageImpl extends Object implements AmqpMessage
| Constructor and Description |
|---|
AmqpMessageImpl(org.apache.qpid.proton.message.Message message) |
AmqpMessageImpl(org.apache.qpid.proton.message.Message message,
ProtonDelivery delivery) |
| 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() |
Instant |
bodyAsTimestamp() |
UUID |
bodyAsUUID() |
String |
contentEncoding() |
String |
contentType() |
String |
correlationId() |
long |
creationTime() |
int |
deliveryCount() |
long |
expiryTime() |
String |
groupId() |
long |
groupSequence() |
String |
id() |
boolean |
isBodyNull() |
boolean |
isDurable() |
boolean |
isFirstAcquirer() |
AmqpMessage |
modified(boolean didItFail,
boolean wasItDeliveredHere)
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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, create, createpublic AmqpMessageImpl(org.apache.qpid.proton.message.Message message,
ProtonDelivery delivery)
public AmqpMessageImpl(org.apache.qpid.proton.message.Message message)
public boolean isDurable()
isDurable in interface AmqpMessagepublic boolean isFirstAcquirer()
isFirstAcquirer in interface AmqpMessagetrue, 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.public int priority()
priority in interface AmqpMessagepublic String id()
id in interface AmqpMessagepublic String address()
address in interface AmqpMessageto fieldpublic String replyTo()
replyTo in interface AmqpMessagepublic String correlationId()
correlationId in interface AmqpMessagepublic boolean isBodyNull()
isBodyNull in interface AmqpMessagenull. This method returns true is the message does not contain a body or
if the message contain a null AMQP value as body.public boolean bodyAsBoolean()
bodyAsBoolean in interface AmqpMessagepublic byte bodyAsByte()
bodyAsByte in interface AmqpMessagepublic short bodyAsShort()
bodyAsShort in interface AmqpMessagepublic int bodyAsInteger()
bodyAsInteger in interface AmqpMessagepublic long bodyAsLong()
bodyAsLong in interface AmqpMessagepublic float bodyAsFloat()
bodyAsFloat in interface AmqpMessagepublic double bodyAsDouble()
bodyAsDouble in interface AmqpMessagepublic char bodyAsChar()
bodyAsChar in interface AmqpMessagepublic Instant bodyAsTimestamp()
bodyAsTimestamp in interface AmqpMessagepublic UUID bodyAsUUID()
bodyAsUUID in interface AmqpMessagepublic Buffer bodyAsBinary()
bodyAsBinary in interface AmqpMessagepublic String bodyAsString()
bodyAsString in interface AmqpMessagepublic String bodyAsSymbol()
bodyAsSymbol in interface AmqpMessagepublic <T> List<T> bodyAsList()
bodyAsList in interface AmqpMessagepublic <K,V> Map<K,V> bodyAsMap()
bodyAsMap in interface AmqpMessagepublic JsonObject bodyAsJsonObject()
bodyAsJsonObject in interface AmqpMessagepublic JsonArray bodyAsJsonArray()
bodyAsJsonArray in interface AmqpMessagepublic String subject()
subject in interface AmqpMessagepublic String contentType()
contentType in interface AmqpMessagepublic String contentEncoding()
contentEncoding in interface AmqpMessagepublic long expiryTime()
expiryTime in interface AmqpMessagepublic long creationTime()
creationTime in interface AmqpMessagepublic long ttl()
ttl in interface AmqpMessagepublic int deliveryCount()
deliveryCount in interface AmqpMessagepublic String groupId()
groupId in interface AmqpMessagepublic String replyToGroupId()
replyToGroupId in interface AmqpMessagepublic long groupSequence()
groupSequence in interface AmqpMessagepublic JsonObject applicationProperties()
applicationProperties in interface AmqpMessagepublic org.apache.qpid.proton.message.Message unwrap()
unwrap in interface AmqpMessagepublic AmqpMessage accepted()
AmqpMessageaccepted status.accepted in interface AmqpMessageAmqpMessage objectpublic AmqpMessage rejected()
AmqpMessagerejected.rejected in interface AmqpMessageAmqpMessage objectpublic AmqpMessage released()
AmqpMessagereleased.released in interface AmqpMessageAmqpMessage objectpublic AmqpMessage modified(boolean didItFail, boolean wasItDeliveredHere)
AmqpMessagemodified.modified in interface AmqpMessagedidItFail - pass true to increase the failed delivery countwasItDeliveredHere - pass true to prevent the re-delivery of the messageAmqpMessage objectCopyright © 2020. All rights reserved.