Package org.springframework.pulsar.config

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

public class MethodPulsarListenerEndpoint<V>
extends AbstractPulsarListenerEndpoint<V>

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

Constructor	Description
MethodPulsarListenerEndpoint()

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageListener(PulsarMessageListenerContainer container, MessageConverter messageConverter)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageListenerInstance(MessageConverter messageConverter)
Object	getBean()
ConsumerBuilderCustomizer<?>	getConsumerBuilderCustomizer()
Method	getMethod()
Boolean	getTransactional()
void	setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff ackTimeoutRedeliveryBackoff)
void	setBean(Object bean)
void	setConsumerBuilderCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer)
void	setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy)
void	setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)
void	setMessagingConverter(SmartMessageConverter messagingConverter)
void	setMethod(Method method)	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)
void	setTransactional(Boolean transactional)

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MethodPulsarListenerEndpoint

public MethodPulsarListenerEndpoint()

Method Details

setBean

public void setBean(Object bean)

getBean

public Object getBean()

setMethod

public void setMethod(Method method)

Set the method to invoke to process a message managed by this endpoint.

Parameters:

method - the target method for the bean.

getMethod

public Method getMethod()

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

createMessageListener

protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageListener(PulsarMessageListenerContainer container,
 @Nullable
 MessageConverter messageConverter)

Specified by:

createMessageListener in class AbstractPulsarListenerEndpoint<V>

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)

createMessageListenerInstance

protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageListenerInstance(@Nullable
 MessageConverter messageConverter)

setMessagingConverter

public void setMessagingConverter(SmartMessageConverter messagingConverter)

setNegativeAckRedeliveryBackoff

public void setNegativeAckRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff negativeAckRedeliveryBackoff)

setDeadLetterPolicy

public void setDeadLetterPolicy(org.apache.pulsar.client.api.DeadLetterPolicy deadLetterPolicy)

setPulsarConsumerErrorHandler

public void setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler pulsarConsumerErrorHandler)

setAckTimeoutRedeliveryBackoff

public void setAckTimeoutRedeliveryBackoff(org.apache.pulsar.client.api.RedeliveryBackoff ackTimeoutRedeliveryBackoff)

getConsumerBuilderCustomizer

public ConsumerBuilderCustomizer<?> getConsumerBuilderCustomizer()

setConsumerBuilderCustomizer

public void setConsumerBuilderCustomizer(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer)

getTransactional

public Boolean getTransactional()

setTransactional

public void setTransactional(Boolean transactional)