Package org.springframework.pulsar.config

Class MethodPulsarReaderEndpoint<V>

java.lang.Object

org.springframework.pulsar.config.AbstractPulsarReaderEndpoint<V>

org.springframework.pulsar.config.MethodPulsarReaderEndpoint<V>

Type Parameters:

V - Message payload type

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, PulsarReaderEndpoint<PulsarMessageReaderContainer>

public class MethodPulsarReaderEndpoint<V>
extends AbstractPulsarReaderEndpoint<V>

A PulsarReaderEndpoint providing the method to invoke to process an incoming message for this endpoint.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
MethodPulsarReaderEndpoint()

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageListenerInstance(MessageConverter messageConverter)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createReaderListener(PulsarMessageReaderContainer container, MessageConverter messageConverter)
Object	getBean()
Method	getMethod()
ReaderBuilderCustomizer<?>	getReaderBuilderCustomizer()
void	setBean(Object bean)
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	setReaderBuilderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)

Methods inherited from class org.springframework.pulsar.config.AbstractPulsarReaderEndpoint

afterPropertiesSet, getAutoStartup, getBeanExpressionContext, getBeanFactory, getBeanResolver, getId, getResolver, getSchemaType, getStartMessageId, getTopics, setAutoStartup, setBeanFactory, setId, setSchemaType, setStartMessageId, setSubscriptionName, setTopics, setupListenerContainer

Methods inherited from class java.lang.Object

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

Constructor Details

MethodPulsarReaderEndpoint

public MethodPulsarReaderEndpoint()

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()

createReaderListener

protected AbstractPulsarMessageToSpringMessageAdapter<V> createReaderListener(PulsarMessageReaderContainer container,
 @Nullable
 MessageConverter messageConverter)

Specified by:

createReaderListener in class AbstractPulsarReaderEndpoint<V>

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener)

createMessageListenerInstance

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

setMessagingConverter

public void setMessagingConverter(SmartMessageConverter messagingConverter)

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

getReaderBuilderCustomizer

public ReaderBuilderCustomizer<?> getReaderBuilderCustomizer()

setReaderBuilderCustomizer

public void setReaderBuilderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)