Uses of Class
io.smallrye.reactive.messaging.rabbitmq.IncomingRabbitMQMessage

Packages that use IncomingRabbitMQMessage

Package	Description
io.smallrye.reactive.messaging.rabbitmq.ack
io.smallrye.reactive.messaging.rabbitmq.fault
io.smallrye.reactive.messaging.rabbitmq.tracing

Uses of IncomingRabbitMQMessage in io.smallrye.reactive.messaging.rabbitmq.ack

Methods in io.smallrye.reactive.messaging.rabbitmq.ack with parameters of type IncomingRabbitMQMessage

Modifier and Type	Method and Description
<V> CompletionStage<Void>	RabbitMQAck.handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context)
<V> CompletionStage<Void>	RabbitMQAutoAck.handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context)
<V> CompletionStage<Void>	RabbitMQAckHandler.handle(IncomingRabbitMQMessage<V> message, io.vertx.mutiny.core.Context context) Handle the request to acknowledge a message.

Uses of IncomingRabbitMQMessage in io.smallrye.reactive.messaging.rabbitmq.fault

Methods in io.smallrye.reactive.messaging.rabbitmq.fault with parameters of type IncomingRabbitMQMessage

Modifier and Type	Method and Description
<V> CompletionStage<Void>	RabbitMQFailStop.handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)
<V> CompletionStage<Void>	RabbitMQAccept.handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)
<V> CompletionStage<Void>	RabbitMQFailureHandler.handle(IncomingRabbitMQMessage<V> message, io.vertx.mutiny.core.Context context, Throwable reason) Handle message failure.
<V> CompletionStage<Void>	RabbitMQReject.handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)

Uses of IncomingRabbitMQMessage in io.smallrye.reactive.messaging.rabbitmq.tracing

Methods in io.smallrye.reactive.messaging.rabbitmq.tracing with parameters of type IncomingRabbitMQMessage

Modifier and Type	Method and Description
static <T> Message<T>	TracingUtils.addIncomingTrace(IncomingRabbitMQMessage<T> msg, String queue, List<String> attributeHeaders) Creates a span based on any tracing metadata in the incoming message.