Class ReactivePulsarListenerAnnotationBeanPostProcessor<V>
java.lang.Object
org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor<V>
- Type Parameters:
V- the payload type.
- All Implemented Interfaces:
Aware,BeanPostProcessor,InitializingBean,SmartInitializingSingleton,ApplicationContextAware,Ordered
public class ReactivePulsarListenerAnnotationBeanPostProcessor<V>
extends Object
implements BeanPostProcessor, Ordered, ApplicationContextAware, InitializingBean, SmartInitializingSingleton
Bean post-processor that registers methods annotated with
ReactivePulsarListener to be invoked by a Pulsar message listener container
created under the covers by a ReactivePulsarListenerContainerFactory according
to the parameters of the annotation.
Annotated methods can use flexible arguments as defined by
ReactivePulsarListener.
This post-processor is automatically registered by the EnableReactivePulsar
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 EnableReactivePulsar
Javadoc for complete usage details.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interface -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringThe bean name of the defaultReactivePulsarListenerContainerFactory.Fields inherited from interface org.springframework.core.Ordered
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidprotected voidintgetOrder()protected StringnoBeanFoundMessage(Object target, String listenerBeanName, String requestedBeanName, Class<?> expectedClass) postProcessAfterInitialization(Object bean, String beanName) postProcessBeforeInitialization(Object bean, String beanName) protected voidprocessListener(MethodReactivePulsarListenerEndpoint<?> endpoint, ReactivePulsarListener ReactivePulsarListener, Object bean, String beanName, String[] topics, String topicPattern) protected voidprocessReactivePulsarListener(ReactivePulsarListener reactivePulsarListener, Method method, Object bean, String beanName) voidsetApplicationContext(ApplicationContext applicationContext) voidsetBeanFactory(BeanFactory beanFactory) voidsetCharset(Charset charset) voidsetDefaultContainerFactoryBeanName(String containerFactoryBeanName) voidsetEndpointRegistry(ReactivePulsarListenerEndpointRegistry<?> endpointRegistry)
-
Field Details
-
DEFAULT_REACTIVE_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME
The bean name of the defaultReactivePulsarListenerContainerFactory.- See Also:
-
-
Constructor Details
-
ReactivePulsarListenerAnnotationBeanPostProcessor
public ReactivePulsarListenerAnnotationBeanPostProcessor()
-
-
Method Details
-
getOrder
public int getOrder() -
setEndpointRegistry
-
setDefaultContainerFactoryBeanName
-
setCharset
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceInitializingBean
-
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- Specified by:
afterSingletonsInstantiatedin interfaceSmartInitializingSingleton
-
postProcessBeforeInitialization
- Specified by:
postProcessBeforeInitializationin interfaceBeanPostProcessor- Throws:
BeansException
-
postProcessAfterInitialization
- Specified by:
postProcessAfterInitializationin interfaceBeanPostProcessor- Throws:
BeansException
-
processReactivePulsarListener
protected void processReactivePulsarListener(ReactivePulsarListener reactivePulsarListener, Method method, Object bean, String beanName) -
processListener
protected void processListener(MethodReactivePulsarListenerEndpoint<?> endpoint, ReactivePulsarListener ReactivePulsarListener, Object bean, String beanName, String[] topics, String topicPattern) -
assertBeanFactory
protected void assertBeanFactory() -
noBeanFoundMessage
-
setApplicationContext
- Specified by:
setApplicationContextin interfaceApplicationContextAware- Throws:
BeansException
-
setBeanFactory
-