io.smallrye.reactive.messaging.rabbitmq

Class IncomingRabbitMQMessage<T>

java.lang.Object

io.smallrye.reactive.messaging.rabbitmq.IncomingRabbitMQMessage<T>

Type Parameters:

T - the message body type

All Implemented Interfaces:

Message<T>

public class IncomingRabbitMQMessage<T>
extends Object
implements Message<T>

An implementation of Message suitable for incoming RabbitMQ messages.

Field Summary

Fields

Modifier and Type	Field and Description
protected io.vertx.rabbitmq.RabbitMQMessage	message
protected Metadata	metadata
protected RabbitMQAckHandler	onAck
protected RabbitMQFailureHandler	onNack
protected IncomingRabbitMQMetadata	rabbitMQMetadata

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

LOGGER

Method Summary

Modifier and Type	Method and Description
CompletionStage<Void>	ack() Acknowledge this message.
void	acknowledgeMessage() Acknowledges the message.
Supplier<CompletionStage<Void>>	getAck()
Optional<String>	getContentEncoding()
Optional<String>	getContentType()
Optional<String>	getCorrelationId()
Optional<ZonedDateTime>	getCreationTime(ZoneId zoneId)
Map<String,Object>	getHeaders()
Optional<String>	getMessageId()
Metadata	getMetadata()
Function<Throwable,CompletionStage<Void>>	getNack()
T	getPayload()
Optional<Integer>	getPriority()
io.vertx.mutiny.rabbitmq.RabbitMQMessage	getRabbitMQMessage()
Optional<String>	getReplyTo()
Optional<String>	getUserId()
void	injectTracingMetadata(TracingMetadata tracingMetadata)
CompletionStage<Void>	nack(Throwable reason, Metadata metadata) Acknowledge negatively this message.
void	rejectMessage(Throwable reason) Rejects the message by nack'ing with requeue=false; this will either discard the message for good or (if a DLQ has been set up) send it to the DLQ.

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, nack, of, of, of, of, of, of, of, of, of, unwrap, withAck, withMetadata, withMetadata, withNack, withPayload

Field Detail

message

protected final io.vertx.rabbitmq.RabbitMQMessage message

metadata

protected Metadata metadata

rabbitMQMetadata

protected final IncomingRabbitMQMetadata rabbitMQMetadata

onNack

protected final RabbitMQFailureHandler onNack

onAck

protected final RabbitMQAckHandler onAck

Method Detail

getAck

public Supplier<CompletionStage<Void>> getAck()

Specified by:

getAck in interface Message<T>

Returns:

the supplier used to retrieve the acknowledgement CompletionStage.

getNack

public Function<Throwable,CompletionStage<Void>> getNack()

Specified by:

getNack in interface Message<T>

Returns:

the function used to retrieve the negative-acknowledgement asynchronous function.

ack

public CompletionStage<Void> ack()

Description copied from interface: Message

Acknowledge this message.

Specified by:

ack in interface Message<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>

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.

acknowledgeMessage

public void acknowledgeMessage()

Acknowledges the message.

rejectMessage

public void rejectMessage(Throwable reason)

Rejects the message by nack'ing with requeue=false; this will either discard the message for good or (if a DLQ has been set up) send it to the DLQ.

Parameters:

reason - the cause of the rejection, which must not be null

getPayload

public T getPayload()

Specified by:

getPayload in interface Message<T>

Returns:

The payload for this message.

getMetadata

public Metadata getMetadata()

Specified by:

getMetadata in interface Message<T>

Returns:

The set of metadata attached to this message, potentially empty.

getPriority

public Optional<Integer> getPriority()

getReplyTo

public Optional<String> getReplyTo()

getUserId

public Optional<String> getUserId()

getMessageId

public Optional<String> getMessageId()

getCreationTime

public Optional<ZonedDateTime> getCreationTime(ZoneId zoneId)

getContentType

public Optional<String> getContentType()

getCorrelationId

public Optional<String> getCorrelationId()

getContentEncoding

public Optional<String> getContentEncoding()

getHeaders

public Map<String,Object> getHeaders()

getRabbitMQMessage

public io.vertx.mutiny.rabbitmq.RabbitMQMessage getRabbitMQMessage()

injectTracingMetadata

public void injectTracingMetadata(TracingMetadata tracingMetadata)