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 HandlerAdapterconfigureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener) protected AbstractPulsarMessageToSpringMessageAdapter<V>createMessageListener(PulsarMessageListenerContainer container, MessageConverter messageConverter) protected AbstractPulsarMessageToSpringMessageAdapter<V>createMessageListenerInstance(MessageConverter messageConverter) getBean()voidsetAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff ackTimeoutRedeliveryBackoff) voidvoidsetConsumerBuilderCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) 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.voidsetNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff negativeAckRedeliveryBackoff) voidsetPulsarConsumerErrorHandler(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:
createMessageListenerin 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) -
setConsumerBuilderCustomizer
-