Package io.vertx.mutiny.amqp
Class AmqpMessage
- java.lang.Object
-
- io.vertx.mutiny.amqp.AmqpMessage
-
public class AmqpMessage extends Object
Represents an AMQP message.Reference about the different metadata can be found on AMQP message properties.
Note that the body is retrieved using
NOTE: This class has been automatically generated from thebody*
method depending on the expected type.original
non Mutiny-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static TypeArg<AmqpMessage>
__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description AmqpMessage(io.vertx.amqp.AmqpMessage delegate)
AmqpMessage(Object delegate)
-
Method Summary
-
-
-
Field Detail
-
__TYPE_ARG
public static final TypeArg<AmqpMessage> __TYPE_ARG
-
-
Constructor Detail
-
AmqpMessage
public AmqpMessage(io.vertx.amqp.AmqpMessage delegate)
-
AmqpMessage
public AmqpMessage(Object delegate)
-
-
Method Detail
-
getDelegate
public io.vertx.amqp.AmqpMessage getDelegate()
-
create
public static AmqpMessageBuilder create()
- Returns:
- a builder to create an
AmqpMessage
.
-
create
public static AmqpMessageBuilder create(AmqpMessage existing)
- Parameters:
existing
- an existing message, must not benull
.- Returns:
- a builder to create an
AmqpMessage
.
-
isDurable
public boolean isDurable()
- Returns:
- whether or not the message is durable.
-
isFirstAcquirer
public boolean isFirstAcquirer()
- Returns:
- if
true
, then this message has not been acquired by any other link. Iffalse
, then this message MAY have previously been acquired by another link or links.
-
priority
public int priority()
- Returns:
- the relative message priority. Higher numbers indicate higher priority messages. Messages with higher priorities MAY be delivered before those with lower priorities.
-
deliveryCount
public int deliveryCount()
- Returns:
- the number of unsuccessful previous attempts to deliver this message. If this value is non-zero it can be taken as an indication that the delivery might be a duplicate. On first delivery, the value is zero. It is incremented upon an outcome being settled at the sender, according to rules defined for each outcome.
-
ttl
public long ttl()
- Returns:
- the duration in milliseconds for which the message is to be considered "live".
-
id
public String id()
- Returns:
- the message id
-
address
public String address()
- Returns:
- the message address, also named
to
field
-
replyTo
public String replyTo()
- Returns:
- The address of the node to send replies to, if any.
-
correlationId
public String correlationId()
- Returns:
- The client-specific id that can be used to mark or identify messages between clients.
-
isBodyNull
public boolean isBodyNull()
- Returns:
- whether the body is
null
. This method returnstrue
is the message does not contain a body or if the message contain anull
AMQP value as body.
-
bodyAsBoolean
public boolean bodyAsBoolean()
- Returns:
- the boolean value contained in the body. The value must be passed as AMQP value.
-
bodyAsByte
public byte bodyAsByte()
- Returns:
- the byte value contained in the body. The value must be passed as AMQP value.
-
bodyAsShort
public short bodyAsShort()
- Returns:
- the short value contained in the body. The value must be passed as AMQP value.
-
bodyAsInteger
public int bodyAsInteger()
- Returns:
- the integer value contained in the body. The value must be passed as AMQP value.
-
bodyAsLong
public long bodyAsLong()
- Returns:
- the long value contained in the body. The value must be passed as AMQP value.
-
bodyAsFloat
public float bodyAsFloat()
- Returns:
- the float value contained in the body. The value must be passed as AMQP value.
-
bodyAsDouble
public double bodyAsDouble()
- Returns:
- the double value contained in the body. The value must be passed as AMQP value.
-
bodyAsChar
public char bodyAsChar()
- Returns:
- the character value contained in the body. The value must be passed as AMQP value.
-
bodyAsBinary
public Buffer bodyAsBinary()
- Returns:
- the bytes contained in the body. The value must be passed as AMQP data.
-
bodyAsString
public String bodyAsString()
- Returns:
- the string value contained in the body. The value must be passed as AMQP value.
-
bodyAsSymbol
public String bodyAsSymbol()
- Returns:
- the symbol value contained in the body. The value must be passed as AMQP value.
-
bodyAsList
public <T> List<T> bodyAsList()
- Returns:
- the list of values contained in the body. The value must be passed as AMQP value.
-
bodyAsJsonObject
public io.vertx.core.json.JsonObject bodyAsJsonObject()
- Returns:
- the JSON object contained in the body. The value must be passed as AMQP data.
-
bodyAsJsonArray
public io.vertx.core.json.JsonArray bodyAsJsonArray()
- Returns:
- the JSON array contained in the body. The value must be passed as AMQP data.
-
subject
public String subject()
-
contentType
public String contentType()
-
contentEncoding
public String contentEncoding()
-
expiryTime
public long expiryTime()
-
creationTime
public long creationTime()
-
groupId
public String groupId()
-
replyToGroupId
public String replyToGroupId()
-
groupSequence
public long groupSequence()
-
applicationProperties
public io.vertx.core.json.JsonObject applicationProperties()
- Returns:
- the message properties as JSON object.
-
accepted
public AmqpMessage accepted()
- Returns:
- the current
AmqpMessage
object
-
rejected
public AmqpMessage rejected()
- Returns:
- the current
AmqpMessage
object
-
released
public AmqpMessage released()
- Returns:
- the current
AmqpMessage
object
-
modified
public AmqpMessage modified(boolean deliveryFailed, boolean undeliverableHere)
- Parameters:
deliveryFailed
- passtrue
to increase the failed delivery countundeliverableHere
- passtrue
to prevent re-delivery of this message to the same consumer- Returns:
- the current
AmqpMessage
object
-
bodyAsTimestamp
public Instant bodyAsTimestamp()
- Returns:
- the timestamp value contained in the body. The value must be passed as AMQP value.
-
bodyAsUUID
public UUID bodyAsUUID()
- Returns:
- the UUID value contained in the body. The value must be passed as AMQP value.
-
newInstance
public static AmqpMessage newInstance(io.vertx.amqp.AmqpMessage arg)
-
-