Package org.springframework.pulsar.reactive.config

Class AbstractReactivePulsarListenerEndpoint<T>

java.lang.Object

org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint<T>

Type Parameters:

T - Message payload type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, ListenerEndpoint<ReactivePulsarMessageListenerContainer<T>>, ReactivePulsarListenerEndpoint<T>

Direct Known Subclasses:

MethodReactivePulsarListenerEndpoint

public abstract class AbstractReactivePulsarListenerEndpoint<T>
extends Object
implements ReactivePulsarListenerEndpoint<T>, BeanFactoryAware, InitializingBean

Base implementation for ReactivePulsarListenerEndpoint.

Author:

Christophe Bornet

Constructor Summary

Constructors

Constructor	Description
AbstractReactivePulsarListenerEndpoint()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected abstract AbstractPulsarMessageToSpringMessageAdapter<T>	createMessageHandler(ReactivePulsarMessageListenerContainer<T> container, MessageConverter messageConverter)
Boolean	getAutoStartup()	Return the autoStartup for this endpoint's container.
protected BeanExpressionContext	getBeanExpressionContext()
protected BeanFactory	getBeanFactory()
protected BeanResolver	getBeanResolver()
Integer	getConcurrency()	Return the concurrency for this endpoint's container.
Boolean	getFluxListener()
String	getId()	Return the id of this endpoint.
protected BeanExpressionResolver	getResolver()
org.apache.pulsar.common.schema.SchemaType	getSchemaType()	Return the schema type for this endpoint's container.
String	getSubscriptionName()	Return the subscription name for this endpoint's container.
org.apache.pulsar.client.api.SubscriptionType	getSubscriptionType()	Return the subscription type for this endpoint's container.
String	getTopicPattern()	Return the topic pattern for this endpoint's container.
List<String>	getTopics()	Return the topics for this endpoint's container.
Boolean	getUseKeyOrderedProcessing()
boolean	isFluxListener()
void	setAutoStartup(Boolean autoStartup)
void	setBeanFactory(BeanFactory beanFactory)
void	setConcurrency(Integer concurrency)	Set the concurrency for this endpoint's container.
void	setFluxListener(boolean fluxListener)
void	setId(String id)
void	setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
void	setSubscriptionName(String subscriptionName)
void	setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType)
void	setTopicPattern(String topicPattern)
void	setTopics(String... topics)
void	setupListenerContainer(ReactivePulsarMessageListenerContainer<T> listenerContainer, MessageConverter messageConverter)	Setup the specified message listener container with the model defined by this endpoint.
void	setUseKeyOrderedProcessing(Boolean useKeyOrderedProcessing)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractReactivePulsarListenerEndpoint

public AbstractReactivePulsarListenerEndpoint()

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getBeanFactory

@Nullable
protected BeanFactory getBeanFactory()

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

getResolver

@Nullable
protected BeanExpressionResolver getResolver()

getBeanExpressionContext

@Nullable
protected BeanExpressionContext getBeanExpressionContext()

getBeanResolver

@Nullable
protected BeanResolver getBeanResolver()

setSubscriptionName

public void setSubscriptionName(String subscriptionName)

getSubscriptionName

@Nullable
public String getSubscriptionName()

Description copied from interface: ListenerEndpoint

Return the subscription name for this endpoint's container.

Specified by:

getSubscriptionName in interface ListenerEndpoint<T>

Returns:

the subscription name.

setId

public void setId(String id)

getId

public String getId()

Description copied from interface: ListenerEndpoint

Return the id of this endpoint.

Specified by:

getId in interface ListenerEndpoint<T>

Returns:

the id of this endpoint. The id can be further qualified when the endpoint is resolved against its actual listener container.

See Also:

• ListenerContainerFactory.createListenerContainer(E)

setTopics

public void setTopics(String... topics)

getTopics

public List<String> getTopics()

Description copied from interface: ListenerEndpoint

Return the topics for this endpoint's container.

Specified by:

getTopics in interface ListenerEndpoint<T>

Returns:

the topics.

setTopicPattern

public void setTopicPattern(String topicPattern)

getTopicPattern

public String getTopicPattern()

Description copied from interface: ListenerEndpoint

Return the topic pattern for this endpoint's container.

Specified by:

getTopicPattern in interface ListenerEndpoint<T>

Returns:

the topic pattern.

getAutoStartup

@Nullable
public Boolean getAutoStartup()

Description copied from interface: ListenerEndpoint

Return the autoStartup for this endpoint's container.

Specified by:

getAutoStartup in interface ListenerEndpoint<T>

Returns:

the autoStartup.

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setupListenerContainer

public void setupListenerContainer(ReactivePulsarMessageListenerContainer<T> listenerContainer,
 @Nullable
 MessageConverter messageConverter)

Description copied from interface: ListenerEndpoint

Setup the specified message listener container with the model defined by this endpoint.

This endpoint must provide the requested missing option(s) of the specified container to make it usable. Usually, this is about setting the queues and the messageListener to use but an implementation may override any default setting that was already set.

Specified by:

setupListenerContainer in interface ListenerEndpoint<T>

Parameters:

listenerContainer - the listener container to configure

messageConverter - the message converter - can be null

createMessageHandler

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

getFluxListener

@Nullable
public Boolean getFluxListener()

setFluxListener

public void setFluxListener(boolean fluxListener)

isFluxListener

public boolean isFluxListener()

Specified by:

isFluxListener in interface ReactivePulsarListenerEndpoint<T>

getSubscriptionType

public org.apache.pulsar.client.api.SubscriptionType getSubscriptionType()

Description copied from interface: ListenerEndpoint

Return the subscription type for this endpoint's container.

Specified by:

getSubscriptionType in interface ListenerEndpoint<T>

Returns:

the subscription type.

setSubscriptionType

public void setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType)

getSchemaType

public org.apache.pulsar.common.schema.SchemaType getSchemaType()

Description copied from interface: ListenerEndpoint

Return the schema type for this endpoint's container.

Specified by:

getSchemaType in interface ListenerEndpoint<T>

Returns:

the schema type.

setSchemaType

public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)

getConcurrency

@Nullable
public Integer getConcurrency()

Description copied from interface: ListenerEndpoint

Return the concurrency for this endpoint's container.

Specified by:

getConcurrency in interface ListenerEndpoint<T>

Returns:

the concurrency.

setConcurrency

public void setConcurrency(Integer concurrency)

Set the concurrency for this endpoint's container.

Parameters:

concurrency - the concurrency.

getUseKeyOrderedProcessing

public Boolean getUseKeyOrderedProcessing()

Specified by:

getUseKeyOrderedProcessing in interface ReactivePulsarListenerEndpoint<T>

setUseKeyOrderedProcessing

public void setUseKeyOrderedProcessing(Boolean useKeyOrderedProcessing)