@Singleton public class KafkaClientIntroductionAdvice extends Object implements MethodInterceptor<Object,Object>, AutoCloseable
KafkaClient
advice annotation.KafkaClient
HOTSWAP, LAZY, PROXY_TARGET
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
KafkaClientIntroductionAdvice(BeanContext beanContext,
KafkaProducerFactory producerFactory,
SerdeRegistry serdeRegistry,
ConversionService<?> conversionService)
Creates the introduction advice for the given arguments.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
Object |
intercept(MethodInvocationContext<Object,Object> context)
Extended version of the
MethodInterceptor.intercept(InvocationContext) method that accepts a MethodInvocationContext . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
intercept
public KafkaClientIntroductionAdvice(BeanContext beanContext, KafkaProducerFactory producerFactory, SerdeRegistry serdeRegistry, ConversionService<?> conversionService)
beanContext
- The bean context.producerFactory
- The producer factory.serdeRegistry
- The serde registryconversionService
- The conversion servicepublic final Object intercept(MethodInvocationContext<Object,Object> context)
MethodInterceptor
MethodInterceptor.intercept(InvocationContext)
method that accepts a MethodInvocationContext
.intercept
in interface MethodInterceptor<Object,Object>
context
- The context@PreDestroy public final void close()
close
in interface AutoCloseable