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 HandlerAdapter
configureListenerAdapter
(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) protected AbstractPulsarMessageToSpringMessageAdapter<V>
createMessageHandler
(ReactivePulsarMessageListenerContainer<V> container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
createMessageListenerInstance
(MessageConverter messageConverter) getBean()
void
void
setConsumerCustomizer
(ReactiveMessageConsumerBuilderCustomizer<V> consumerCustomizer) void
setDeadLetterPolicy
(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) void
setMessageHandlerMethodFactory
(MessageHandlerMethodFactory messageHandlerMethodFactory) void
setMessagingConverter
(SmartMessageConverter messagingConverter) void
Set 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:
createMessageHandler
in 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) -
getConsumerCustomizer
-
setConsumerCustomizer
-