Class MethodPulsarListenerEndpoint<V>
java.lang.Object
org.springframework.pulsar.config.AbstractPulsarListenerEndpoint<V>
org.springframework.pulsar.config.MethodPulsarListenerEndpoint<V>
- Type Parameters:
V
- Message payload type
- All Implemented Interfaces:
Aware
,BeanFactoryAware
,InitializingBean
,ListenerEndpoint<PulsarMessageListenerContainer>
,PulsarListenerEndpoint
A
PulsarListenerEndpoint
providing the method to invoke to process an incoming
message for this endpoint.- Author:
- Soby Chacko, Alexander Preuß, Chris Bono
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected HandlerAdapter
configureListenerAdapter
(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) protected AbstractPulsarMessageToSpringMessageAdapter<V>
createMessageListener
(PulsarMessageListenerContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>
createMessageListenerInstance
(MessageConverter messageConverter) getBean()
void
setAckTimeoutRedeliveryBackoff
(org.apache.pulsar.client.api.RedeliveryBackoff ackTimeoutRedeliveryBackoff) void
void
setConsumerBuilderCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) 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.void
setNegativeAckRedeliveryBackoff
(org.apache.pulsar.client.api.RedeliveryBackoff negativeAckRedeliveryBackoff) void
setPulsarConsumerErrorHandler
(PulsarConsumerErrorHandler pulsarConsumerErrorHandler) Methods inherited from class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint
afterPropertiesSet, getAckMode, getAutoStartup, getBatchListener, getBeanExpressionContext, getBeanFactory, getBeanResolver, getConcurrency, getConsumerProperties, getId, getResolver, getSchemaType, getSubscriptionName, getSubscriptionType, getTopicPattern, getTopics, isBatchListener, setAckMode, setAutoStartup, setBatchListener, setBeanFactory, setConcurrency, setConsumerProperties, setId, setSchemaType, setSubscriptionName, setSubscriptionType, setTopicPattern, setTopics, setupListenerContainer
-
Constructor Details
-
MethodPulsarListenerEndpoint
public MethodPulsarListenerEndpoint()
-
-
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
-
createMessageListener
protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageListener(PulsarMessageListenerContainer container, @Nullable MessageConverter messageConverter) - Specified by:
createMessageListener
in classAbstractPulsarListenerEndpoint<V>
-
configureListenerAdapter
protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) -
createMessageListenerInstance
protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageListenerInstance(@Nullable MessageConverter messageConverter) -
setMessagingConverter
-
setNegativeAckRedeliveryBackoff
public void setNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff negativeAckRedeliveryBackoff) -
setDeadLetterPolicy
public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy) -
setPulsarConsumerErrorHandler
-
setAckTimeoutRedeliveryBackoff
public void setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff ackTimeoutRedeliveryBackoff) -
getConsumerBuilderCustomizer
-
setConsumerBuilderCustomizer
-