@InterceptorBean(value=KafkaClient.class) public class KafkaClientIntroductionAdvice extends java.lang.Object implements io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>, java.lang.AutoCloseable
KafkaClient
advice annotation.KafkaClient
Constructor and Description |
---|
KafkaClientIntroductionAdvice(io.micronaut.context.BeanContext beanContext,
SerdeRegistry serdeRegistry,
io.micronaut.core.convert.ConversionService<?> conversionService)
Creates the introduction advice for the given arguments.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.Object |
intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context) |
public KafkaClientIntroductionAdvice(io.micronaut.context.BeanContext beanContext, SerdeRegistry serdeRegistry, io.micronaut.core.convert.ConversionService<?> conversionService)
beanContext
- The bean context.serdeRegistry
- The serde registryconversionService
- The conversion servicepublic final java.lang.Object intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
intercept
in interface io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>
@PreDestroy public final void close()
close
in interface java.lang.AutoCloseable