java.lang.Object
- io.smallrye.reactive.messaging.amqp.AmqpMessage<T>
- - io.smallrye.reactive.messaging.amqp.OutgoingAmqpMessage<T>

All Implemented Interfaces:: Message<T>

public class OutgoingAmqpMessage<T>
extends AmqpMessage<T>
implements Message<T>

Field Summary
- Fields inherited from class io.smallrye.reactive.messaging.amqp.AmqpMessage
  APPLICATION_JSON, message, onNack
- Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message
  LOGGER

Constructor Summary

Constructors
Constructor Description

OutgoingAmqpMessage(io.vertx.mutiny.amqp.AmqpMessage message, OutgoingAmqpMetadata amqpMetadata)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CompletionStage<Void>`	`ack()`	Acknowledge this message.
`Supplier<CompletionStage<Void>>`	`getAck()`
`String`	`getAddress()`
`io.vertx.core.json.JsonObject`	`getApplicationProperties()`
`String`	`getContentEncoding()`
`String`	`getContentType()`
`Object`	`getCorrelationId()`
`String`	`getGroupId()`
`Object`	`getMessageId()`
`Metadata`	`getMetadata()`
`Function<Throwable,CompletionStage<Void>>`	`getNack()`
`int`	`getPriority()`
`String`	`getSubject()`
`long`	`getTtl()`
`boolean`	`isDurable()`
`CompletionStage<Void>`	`nack(Throwable reason)`	Acknowledge negatively this message.

Methods inherited from class io.smallrye.reactive.messaging.amqp.AmqpMessage
builder, getAmqpMessage, getBody, getCreationTime, getDeliveryCount, getError, getExpiryTime, getGroupSequence, getPayload, unwrap

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message
addMetadata, getMetadata, getPayload, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload

- Constructor Detail
  - OutgoingAmqpMessage
```
public OutgoingAmqpMessage(io.vertx.mutiny.amqp.AmqpMessage message,
                           OutgoingAmqpMetadata amqpMetadata)
```
- Method Detail
  - getMetadata
```
public Metadata getMetadata()
```
    Specified by:
    
    getMetadata in interface Message<T>
    
    Overrides:
    
    getMetadata in class AmqpMessage<T>
    
    Returns:
    
    The set of metadata attached to this message, potentially empty.
  - isDurable
```
public boolean isDurable()
```
    Overrides:
    
    isDurable in class AmqpMessage<T>
  - getPriority
```
public int getPriority()
```
    Overrides:
    
    getPriority in class AmqpMessage<T>
  - getTtl
```
public long getTtl()
```
    Overrides:
    
    getTtl in class AmqpMessage<T>
  - getMessageId
```
public Object getMessageId()
```
    Overrides:
    
    getMessageId in class AmqpMessage<T>
  - getAddress
```
public String getAddress()
```
    Overrides:
    
    getAddress in class AmqpMessage<T>
  - getGroupId
```
public String getGroupId()
```
    Overrides:
    
    getGroupId in class AmqpMessage<T>
  - getContentType
```
public String getContentType()
```
    Overrides:
    
    getContentType in class AmqpMessage<T>
  - getCorrelationId
```
public Object getCorrelationId()
```
    Overrides:
    
    getCorrelationId in class AmqpMessage<T>
  - getContentEncoding
```
public String getContentEncoding()
```
    Overrides:
    
    getContentEncoding in class AmqpMessage<T>
  - getSubject
```
public String getSubject()
```
    Overrides:
    
    getSubject in class AmqpMessage<T>
  - ack
```
public CompletionStage<Void> ack()
```
    Description copied from interface: Message
    
    Acknowledge this message.
    
    Specified by:
    
    ack in interface Message<T>
    
    Overrides:
    
    ack in class AmqpMessage<T>
    
    Returns:
    
    a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.
  - nack
```
public CompletionStage<Void> nack(Throwable reason)
```
    Description copied from interface: Message
    
    Acknowledge negatively this message. nack is used to indicate that the processing of a message failed. The reason is passed as parameter.
    
    Specified by:
    
    nack in interface Message<T>
    
    Overrides:
    
    nack in class AmqpMessage<T>
    
    Parameters:
    
    reason - the reason of the nack, must not be null
    
    Returns:
    
    a completion stage completed when the message is negative-acknowledgement has completed. If the negative acknowledgement fails, the completion stage propagates the failure.
  - getAck
```
public Supplier<CompletionStage<Void>> getAck()
```
    Specified by:
    
    getAck in interface Message<T>
    
    Overrides:
    
    getAck in class AmqpMessage<T>
    
    Returns:
    
    the supplier used to retrieve the acknowledgement CompletionStage.
  - getNack
```
public Function<Throwable,CompletionStage<Void>> getNack()
```
    Specified by:
    
    getNack in interface Message<T>
    
    Overrides:
    
    getNack in class AmqpMessage<T>
    
    Returns:
    
    the function used to retrieve the negative-acknowledgement asynchronous function.
  - getApplicationProperties
```
public io.vertx.core.json.JsonObject getApplicationProperties()
```
    Overrides:
    
    getApplicationProperties in class AmqpMessage<T>

Class OutgoingAmqpMessage<T>

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.amqp.AmqpMessage

Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message

Constructor Summary

Method Summary

Methods inherited from class io.smallrye.reactive.messaging.amqp.AmqpMessage

Methods inherited from class java.lang.Object

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

Constructor Detail

OutgoingAmqpMessage

Method Detail

getMetadata

isDurable

getPriority

getTtl

getMessageId

getAddress

getGroupId

getContentType

getCorrelationId

getContentEncoding

getSubject

ack

nack

getAck

getNack

getApplicationProperties