Package io.micronaut.rabbitmq.bind
package io.micronaut.rabbitmq.bind
Classes for binding RabbitMQ messages to consumer methods.
- Since:
- 1.1.0
- Author:
- James Kleeh
-
ClassDescriptionAcknowledgementBinder<T extends io.micronaut.messaging.Acknowledgement>Binds an argument of type
Acknowledgement
from theRabbitConsumerState
.Represents options for controlling the acknowledgment actions.A contract for acknowledging or rejecting RabbitMQ messages.Binds an argument of typeRabbitAcknowledgement
from theRabbitConsumerState
.RabbitAnnotatedArgumentBinder<A extends Annotation>An interface for RabbitMQ argument binding based on an annotation.An interface for RabbitMQ argument binding.Binds an argument of typeBasicProperties
from theRabbitConsumerState
.Used to determine whichRabbitArgumentBinder
to use for any given argument.Binds an argument of with theMessageBody
annotation from theRabbitConsumerState
.Binds an argument of typeChannel
from theRabbitConsumerState
.Stores the state of a RabbitMQ message to be consumed.The default binder for binding an argument from theRabbitConsumerState
that is used if no other binder supports the argument.Binds an argument of typeEnvelope
from theRabbitConsumerState
.Binds an argument of with theMessageHeader
annotation from theRabbitConsumerState
.Converts RabbitMQ header values to the requested type.Binds an argument of with theRabbitHeaders
annotation from theRabbitConsumerState
.Responsible for acknowledging or rejecting a message.Binds an argument of with theRabbitProperty
annotation from theRabbitConsumerState
.An interface for RabbitMQ argument binding based on argument type.