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 Description <V> CompletionStage<Void>RabbitMQAck. 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.<V> CompletionStage<Void>RabbitMQAutoAck. handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context) -
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 Description <V> CompletionStage<Void>RabbitMQAccept. handle(IncomingRabbitMQMessage<V> msg, io.vertx.mutiny.core.Context context, Throwable reason)<V> CompletionStage<Void>RabbitMQFailStop. 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 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.
-