Class PulsarReaderAnnotationBeanPostProcessor<V>

java.lang.Object
org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor<V>
Type Parameters:
V - the payload type.
All Implemented Interfaces:
Aware, BeanPostProcessor, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Ordered

public class PulsarReaderAnnotationBeanPostProcessor<V> extends AbstractPulsarAnnotationsBeanPostProcessor implements SmartInitializingSingleton
Bean post-processor that registers methods annotated with PulsarListener to be invoked by a Pulsar message listener container created under the covers by a PulsarReaderContainerFactory according to the parameters of the annotation.

Annotated methods can use flexible arguments as defined by PulsarListener.

This post-processor is automatically registered by the EnablePulsar annotation.

Auto-detect any PulsarListenerConfigurer instances in the container, allowing for customization of the registry to be used, the default container factory or for fine-grained control over endpoints registration. See EnablePulsar Javadoc for complete usage details.

Author:
Soby Chacko, Jihoon Kim
See Also: