Class MethodPulsarReaderEndpoint<V>

java.lang.Object

org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint<V>

org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint<V>

Type Parameters:

V - Message payload type

All Implemented Interfaces:

PulsarReaderEndpoint<PulsarMessageReaderContainer>, Aware, BeanFactoryAware, InitializingBean

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, Jihoon Kim

Constructor Summary

Constructors

Constructor	Description
MethodPulsarReaderEndpoint()

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener, MessageHandlerMethodFactory messageHandlerMethodFactory)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createMessageListenerInstance(@Nullable MessageConverter messageConverter)
protected AbstractPulsarMessageToSpringMessageAdapter<V>	createReaderListener(PulsarMessageReaderContainer container, @Nullable MessageConverter messageConverter)
@Nullable Object	getBean()
@Nullable Method	getMethod()
@Nullable ReaderBuilderCustomizer<?>	getReaderBuilderCustomizer()
protected Object	requireNonNullBean()
protected MessageHandlerMethodFactory	requireNonNullMessageHandlerMethodFactory()
protected Method	requireNonNullMethod()
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	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	setReaderBuilderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)
void	setTrustedPackages(String... trustedPackages)	Add packages to trust for header deserialization.

Methods inherited from class AbstractPulsarReaderEndpoint

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

Methods inherited from class 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 @Nullable Object getBean()

requireNonNullBean

protected Object requireNonNullBean()

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 @Nullable Method getMethod()

requireNonNullMethod

protected Method requireNonNullMethod()

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

setTrustedPackages

public void setTrustedPackages(String... trustedPackages)

Add packages to trust for header deserialization. Trust is by exact package match; sub-packages are not trusted transitively. The given packages are added to JsonPulsarHeaderMapper.DEFAULT_TRUSTED_PACKAGES, which are always included. Pass "*" as the sole entry to trust all packages (not recommended for untrusted message sources).

Parameters:

trustedPackages - packages to add to the trusted list for header deserialization

createReaderListener

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

Specified by:

createReaderListener in class AbstractPulsarReaderEndpoint<V>

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V> messageListener,
 MessageHandlerMethodFactory messageHandlerMethodFactory)

createMessageListenerInstance

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

setMessagingConverter

public void setMessagingConverter(SmartMessageConverter messagingConverter)

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

requireNonNullMessageHandlerMethodFactory

protected MessageHandlerMethodFactory requireNonNullMessageHandlerMethodFactory()

getReaderBuilderCustomizer

public @Nullable ReaderBuilderCustomizer<?> getReaderBuilderCustomizer()

setReaderBuilderCustomizer

public void setReaderBuilderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)