Class MethodReactivePulsarListenerEndpoint<V>
java.lang.Object
org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint<V>
org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint<V>
- Type Parameters:
V- Message payload type
- All Implemented Interfaces:
Aware,BeanFactoryAware,InitializingBean,ListenerEndpoint<ReactivePulsarMessageListenerContainer<V>>,ReactivePulsarListenerEndpoint<V>
public class MethodReactivePulsarListenerEndpoint<V>
extends AbstractReactivePulsarListenerEndpoint<V>
A
ReactivePulsarListenerEndpoint providing the method to invoke to process an
incoming message for this endpoint.- Author:
- Christophe Bornet, Chris Bono
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected HandlerAdapterconfigureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) protected AbstractPulsarMessageToSpringMessageAdapter<V>createMessageHandler(ReactivePulsarMessageListenerContainer<V> container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>createMessageListenerInstance(MessageConverter messageConverter) getBean()voidvoidsetConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<V> consumerCustomizer) voidsetDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) voidsetMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory) voidsetMessagingConverter(SmartMessageConverter messagingConverter) voidSet the method to invoke to process a message managed by this endpoint.Methods inherited from class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint
afterPropertiesSet, getAutoStartup, getBeanExpressionContext, getBeanFactory, getBeanResolver, getConcurrency, getFluxListener, getId, getResolver, getSchemaType, getSubscriptionName, getSubscriptionType, getTopicPattern, getTopics, getUseKeyOrderedProcessing, isFluxListener, setAutoStartup, setBeanFactory, setConcurrency, setFluxListener, setId, setSchemaType, setSubscriptionName, setSubscriptionType, setTopicPattern, setTopics, setupListenerContainer, setUseKeyOrderedProcessing
-
Constructor Details
-
MethodReactivePulsarListenerEndpoint
public MethodReactivePulsarListenerEndpoint()
-
-
Method Details
-
setBean
-
getBean
-
setMethod
Set the method to invoke to process a message managed by this endpoint.- Parameters:
method- the target method for thebean.
-
getMethod
-
setMessageHandlerMethodFactory
-
createMessageHandler
protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageHandler(ReactivePulsarMessageListenerContainer<V> container, @Nullable MessageConverter messageConverter) - Specified by:
createMessageHandlerin classAbstractReactivePulsarListenerEndpoint<V>
-
configureListenerAdapter
protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) -
createMessageListenerInstance
protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageListenerInstance(@Nullable MessageConverter messageConverter) -
setMessagingConverter
-
setDeadLetterPolicy
public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
setConsumerCustomizer
-