Package org.springframework.pulsar.reactive.config

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

Constructor	Description
MethodReactivePulsarListenerEndpoint()

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageHandler(ReactivePulsarMessageListenerContainer<V> container, MessageConverter messageConverter)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageListenerInstance(MessageConverter messageConverter)
Object	getBean()
ReactiveMessageConsumerBuilderCustomizer<V>	getConsumerCustomizer()
Method	getMethod()
void	setBean(Object bean)
void	setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<V> consumerCustomizer)
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.

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

Methods inherited from class java.lang.Object

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

Constructor Details

MethodReactivePulsarListenerEndpoint

public MethodReactivePulsarListenerEndpoint()

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)

createMessageHandler

protected AbstractPulsarMessageToSpringMessageAdapter<V> createMessageHandler(ReactivePulsarMessageListenerContainer<V> container,
 @Nullable
 MessageConverter messageConverter)

Specified by:

createMessageHandler in class AbstractReactivePulsarListenerEndpoint<V>

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)

createMessageListenerInstance

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

setMessagingConverter

public void setMessagingConverter(SmartMessageConverter messagingConverter)

setDeadLetterPolicy

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

getConsumerCustomizer

public ReactiveMessageConsumerBuilderCustomizer<V> getConsumerCustomizer()

setConsumerCustomizer

public void setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<V> consumerCustomizer)