Package io.micronaut.rabbitmq.intercept
package io.micronaut.rabbitmq.intercept
Contains the implementations of the
Around advices for
RabbitMQ consumer and producer methods.- Since:
- 1.1.0
- Author:
- James Kleeh
-
ClassDescriptionA default
Consumerthat delegates cancelled or shutdown with a single methodDefaultConsumer.handleTerminate(String).A class that stores the basic properties in a mutable state.AnExecutableMethodProcessorthat will process all beans annotated withRabbitListenerand create and subscribe the relevant methods as consumers to RabbitMQ queues.Implementation of theRabbitClientadvice annotation.