@Singleton
public class RabbitMQIntroductionAdvice
extends java.lang.Object
implements io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>
RabbitClient advice annotation.RabbitClient| Constructor and Description |
|---|
RabbitMQIntroductionAdvice(io.micronaut.context.BeanContext beanContext,
io.micronaut.core.convert.ConversionService<?> conversionService,
RabbitMessageSerDesRegistry serDesRegistry,
java.util.concurrent.ExecutorService executorService)
Default constructor.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.Object |
intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context) |
public RabbitMQIntroductionAdvice(io.micronaut.context.BeanContext beanContext,
io.micronaut.core.convert.ConversionService<?> conversionService,
RabbitMessageSerDesRegistry serDesRegistry,
@Named(value="io")
java.util.concurrent.ExecutorService executorService)
beanContext - The bean contextconversionService - The conversion serviceserDesRegistry - The registry to find a serDes to serialize the bodyexecutorService - The executor to execute reactive operations on