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
Consumer
that delegates cancelled or shutdown with a single methodDefaultConsumer.handleTerminate(String)
.A class that stores the basic properties in a mutable state.AnExecutableMethodProcessor
that will process all beans annotated withRabbitListener
and create and subscribe the relevant methods as consumers to RabbitMQ queues.Implementation of theRabbitClient
advice annotation.