AmqpMessage (Vert.x Stack - Docs 3.9.15 API)

```
public interface AmqpMessage
```
Represents an AMQP message.
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.

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Default Methods
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()`

- Method Detail
  - create
```
static AmqpMessageBuilder create()
```
    Returns:
    
    a builder to create an AmqpMessage.
  - create
```
static AmqpMessageBuilder create(AmqpMessage existing)
```
    Creates a builder to create a new AmqpMessage copying the metadata from the passed message.
    
    Parameters:
    
    existing - an existing message, must not be null.
    
    Returns:
    
    a builder to create an AmqpMessage.
  - create
```
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.
    
    Parameters:
    
    existing - an existing (Proton) message, must not be null.
    
    Returns:
    
    a builder to create an AmqpMessage.
  - isDurable
```
boolean isDurable()
```
    Returns:
    
    whether or not the message is durable.
    
    See Also:
    
    AMQP specification
  - isFirstAcquirer
```
boolean isFirstAcquirer()
```
    Returns:
    
    if 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.
    
    See Also:
    
    AMQP specification
  - priority
```
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.
    
    See Also:
    
    AMQP specification
  - deliveryCount
```
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.
    
    See Also:
    
    AMQP specification
  - ttl
```
long ttl()
```
    Returns:
    
    the duration in milliseconds for which the message is to be considered "live".
    
    See Also:
    
    AMQP specification
  - id
```
String id()
```
    Returns:
    
    the message id
    
    See Also:
    
    AMQP specification
  - address
```
String address()
```
    Returns:
    
    the message address, also named to field
    
    See Also:
    
    AMQP specification
  - replyTo
```
String replyTo()
```
    Returns:
    
    The address of the node to send replies to, if any.
    
    See Also:
    
    AMQP specification
  - correlationId
```
String correlationId()
```
    Returns:
    
    The client-specific id that can be used to mark or identify messages between clients.
    
    See Also:
    
    AMQP specification
  - isBodyNull
```
boolean isBodyNull()
```
    Returns:
    
    whether the body is null. This method returns true is the message does not contain a body or if the message contain a null AMQP value as body.
  - bodyAsBoolean
```
boolean bodyAsBoolean()
```
    Returns:
    
    the boolean value contained in the body. The value must be passed as AMQP value.
  - bodyAsByte
```
byte bodyAsByte()
```
    Returns:
    
    the byte value contained in the body. The value must be passed as AMQP value.
  - bodyAsShort
```
short bodyAsShort()
```
    Returns:
    
    the short value contained in the body. The value must be passed as AMQP value.
  - bodyAsInteger
```
int bodyAsInteger()
```
    Returns:
    
    the integer value contained in the body. The value must be passed as AMQP value.
  - bodyAsLong
```
long bodyAsLong()
```
    Returns:
    
    the long value contained in the body. The value must be passed as AMQP value.
  - bodyAsFloat
```
float bodyAsFloat()
```
    Returns:
    
    the float value contained in the body. The value must be passed as AMQP value.
  - bodyAsDouble
```
double bodyAsDouble()
```
    Returns:
    
    the double value contained in the body. The value must be passed as AMQP value.
  - bodyAsChar
```
char bodyAsChar()
```
    Returns:
    
    the character value contained in the body. The value must be passed as AMQP value.
  - bodyAsTimestamp
```
java.time.Instant bodyAsTimestamp()
```
    Returns:
    
    the timestamp value contained in the body. The value must be passed as AMQP value.
  - bodyAsUUID
```
UUID bodyAsUUID()
```
    Returns:
    
    the UUID value contained in the body. The value must be passed as AMQP value.
  - bodyAsBinary
```
Buffer bodyAsBinary()
```
    Returns:
    
    the bytes contained in the body. The value must be passed as AMQP data.
  - bodyAsString
```
String bodyAsString()
```
    Returns:
    
    the string value contained in the body. The value must be passed as AMQP value.
  - bodyAsSymbol
```
String bodyAsSymbol()
```
    Returns:
    
    the symbol value contained in the body. The value must be passed as AMQP value.
  - bodyAsList
```
<T> List<T> bodyAsList()
```
    Returns:
    
    the list of values contained in the body. The value must be passed as AMQP value.
  - bodyAsMap
```
<K,V> Map<K,V> bodyAsMap()
```
    Returns:
    
    the map contained in the body. The value must be passed as AMQP value.
  - bodyAsJsonObject
```
JsonObject bodyAsJsonObject()
```
    Returns:
    
    the JSON object contained in the body. The value must be passed as AMQP data.
  - bodyAsJsonArray
```
JsonArray bodyAsJsonArray()
```
    Returns:
    
    the JSON array contained in the body. The value must be passed as AMQP data.
  - subject
```
String subject()
```
  - contentType
```
String contentType()
```
  - contentEncoding
```
String contentEncoding()
```
  - expiryTime
```
long expiryTime()
```
  - creationTime
```
long creationTime()
```
  - groupId
```
String groupId()
```
  - replyToGroupId
```
String replyToGroupId()
```
  - groupSequence
```
long groupSequence()
```
  - applicationProperties
```
JsonObject applicationProperties()
```
    Returns:
    
    the message properties as JSON object.
  - unwrap
```
org.apache.qpid.proton.message.Message unwrap()
```
  - accepted
```
AmqpMessage accepted()
```
    When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message. It marks the message as delivered with the accepted status.
    
    Returns:
    
    the current AmqpMessage object
    
    Throws:
    
    IllegalStateException - is the current message is not a received message.
  - rejected
```
AmqpMessage rejected()
```
    When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as rejected.
    
    Returns:
    
    the current AmqpMessage object
    
    Throws:
    
    IllegalStateException - is the current message is not a received message.
  - released
```
AmqpMessage released()
```
    When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as released.
    
    Returns:
    
    the current AmqpMessage object
    
    Throws:
    
    IllegalStateException - is the current message is not a received message.
  - modified
```
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.
    
    Parameters:
    
    deliveryFailed - pass true to increase the failed delivery count
    
    undeliverableHere - pass true to prevent re-delivery of this message to the same consumer
    
    Returns:
    
    the current AmqpMessage object
    
    Throws:
    
    IllegalStateException - is the current message is not a received message.

Interface AmqpMessage

Method Summary

Method Detail

create

create

create

isDurable

isFirstAcquirer

priority

deliveryCount

ttl

id

address

replyTo

correlationId

isBodyNull

bodyAsBoolean

bodyAsByte

bodyAsShort

bodyAsInteger

bodyAsLong

bodyAsFloat

bodyAsDouble

bodyAsChar

bodyAsTimestamp

bodyAsUUID

bodyAsBinary

bodyAsString

bodyAsSymbol

bodyAsList

bodyAsMap

bodyAsJsonObject

bodyAsJsonArray

subject

contentType

contentEncoding

expiryTime

creationTime

groupId

replyToGroupId

groupSequence

applicationProperties

unwrap

accepted

rejected

released

modified