public class AmqpMessage extends Object
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.
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<AmqpMessage> |
__TYPE_ARG |
Constructor and Description |
---|
AmqpMessage(AmqpMessage delegate) |
AmqpMessage(Object delegate) |
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() |
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. |
long |
creationTime() |
int |
deliveryCount() |
boolean |
equals(Object o) |
long |
expiryTime() |
AmqpMessage |
getDelegate() |
String |
groupId() |
long |
groupSequence() |
int |
hashCode() |
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 . |
static AmqpMessage |
newInstance(AmqpMessage arg) |
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() |
String |
toString() |
long |
ttl() |
public static final io.vertx.lang.rx.TypeArg<AmqpMessage> __TYPE_ARG
public AmqpMessage(AmqpMessage delegate)
public AmqpMessage(Object delegate)
public AmqpMessage getDelegate()
public static AmqpMessageBuilder create()
AmqpMessage
.public static AmqpMessageBuilder create(AmqpMessage existing)
AmqpMessage
copying the metadata from the passed message.existing
- an existing message, must not be null
.AmqpMessage
.public boolean isDurable()
public 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.public int priority()
public int deliveryCount()
public long ttl()
public String id()
public String address()
to
fieldpublic String replyTo()
public String correlationId()
public 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.public boolean bodyAsBoolean()
public byte bodyAsByte()
public short bodyAsShort()
public int bodyAsInteger()
public long bodyAsLong()
public float bodyAsFloat()
public double bodyAsDouble()
public char bodyAsChar()
public Buffer bodyAsBinary()
public String bodyAsString()
public String bodyAsSymbol()
public <T> List<T> bodyAsList()
public JsonObject bodyAsJsonObject()
public JsonArray bodyAsJsonArray()
public String subject()
public String contentType()
public String contentEncoding()
public long expiryTime()
public long creationTime()
public String groupId()
public String replyToGroupId()
public long groupSequence()
public JsonObject applicationProperties()
public AmqpMessage accepted()
accepted
status.AmqpMessage
objectpublic AmqpMessage rejected()
rejected
.AmqpMessage
objectpublic AmqpMessage released()
released
.AmqpMessage
objectpublic 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
objectpublic java.time.Instant bodyAsTimestamp()
public UUID bodyAsUUID()
public static AmqpMessage newInstance(AmqpMessage arg)
Copyright © 2023 Eclipse. All rights reserved.