Package org.springframework.pulsar.config

Class AbstractPulsarListenerEndpoint<K>

java.lang.Object

org.springframework.pulsar.config.AbstractPulsarListenerEndpoint<K>

Type Parameters:

K - Message payload type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, ListenerEndpoint<PulsarMessageListenerContainer>, PulsarListenerEndpoint

Direct Known Subclasses:

MethodPulsarListenerEndpoint

public abstract class AbstractPulsarListenerEndpoint<K>
extends Object
implements PulsarListenerEndpoint, BeanFactoryAware, InitializingBean

Base implementation for PulsarListenerEndpoint.

Author:

Soby Chacko, Alexander Preuß

Constructor Summary

Constructors

Constructor	Description
AbstractPulsarListenerEndpoint()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected abstract AbstractPulsarMessageToSpringMessageAdapter<K>	createMessageListener(PulsarMessageListenerContainer container, MessageConverter messageConverter)
AckMode	getAckMode()
Boolean	getAutoStartup()	Return the autoStartup for this endpoint's container.
Boolean	getBatchListener()
protected BeanExpressionContext	getBeanExpressionContext()
protected BeanFactory	getBeanFactory()
protected BeanResolver	getBeanResolver()
Integer	getConcurrency()	Return the concurrency for this endpoint's container.
Properties	getConsumerProperties()
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.
Collection<String>	getTopics()	Return the topics for this endpoint's container.
boolean	isBatchListener()
void	setAckMode(AckMode ackMode)
void	setAutoStartup(Boolean autoStartup)
void	setBatchListener(boolean batchListener)
void	setBeanFactory(BeanFactory beanFactory)
void	setConcurrency(Integer concurrency)	Set the concurrency for this endpoint's container.
void	setConsumerProperties(Properties consumerProperties)
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(PulsarMessageListenerContainer listenerContainer, MessageConverter messageConverter)	Setup the specified message listener container with the model defined by this endpoint.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractPulsarListenerEndpoint

public AbstractPulsarListenerEndpoint()

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<K>

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<K>

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 Collection<String> getTopics()

Description copied from interface: ListenerEndpoint

Return the topics for this endpoint's container.

Specified by:

getTopics in interface ListenerEndpoint<K>

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<K>

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<K>

Returns:

the autoStartup.

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setupListenerContainer

public void setupListenerContainer(PulsarMessageListenerContainer 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<K>

Parameters:

listenerContainer - the listener container to configure

messageConverter - the message converter - can be null

createMessageListener

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

setConsumerProperties

public void setConsumerProperties(Properties consumerProperties)

getConsumerProperties

public Properties getConsumerProperties()

Specified by:

getConsumerProperties in interface PulsarListenerEndpoint

getBatchListener

@Nullable
public Boolean getBatchListener()

setBatchListener

public void setBatchListener(boolean batchListener)

isBatchListener

public boolean isBatchListener()

Specified by:

isBatchListener in interface PulsarListenerEndpoint

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<K>

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<K>

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<K>

Returns:

the concurrency.

setConcurrency

public void setConcurrency(Integer concurrency)

Set the concurrency for this endpoint's container.

Parameters:

concurrency - the concurrency.

getAckMode

public AckMode getAckMode()

Specified by:

getAckMode in interface PulsarListenerEndpoint

setAckMode

public void setAckMode(AckMode ackMode)