io.smallrye.reactive.messaging.amqp

Class OutgoingAmqpMessage<T>

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 and Description
OutgoingAmqpMessage(io.vertx.mutiny.amqp.AmqpMessage message, OutgoingAmqpMetadata amqpMetadata)

Method Summary

Modifier and Type	Method and 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, Metadata metadata) 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, nack, of, of, of, of, of, of, of, of, of, 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,
                                  Metadata metadata)

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. Additional metadata may be provided that the connector can use when nacking the message. The interpretation of metadata is connector-specific.

Specified by:

nack in interface Message<T>

Overrides:

nack in class AmqpMessage<T>

Parameters:

reason - the reason of the nack, must not be null

metadata - additional nack metadata the connector may use, may 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>