Class AbstractPulsarReaderEndpoint<K>

java.lang.Object

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

Type Parameters:

K - Message payload type.

All Implemented Interfaces:

PulsarReaderEndpoint<PulsarMessageReaderContainer>, Aware, BeanFactoryAware, InitializingBean

Direct Known Subclasses:

MethodPulsarReaderEndpoint

public abstract class AbstractPulsarReaderEndpoint<K>
extends Object
implements PulsarReaderEndpoint<PulsarMessageReaderContainer>, BeanFactoryAware, InitializingBean

Base implementation for PulsarListenerEndpoint.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
AbstractPulsarReaderEndpoint()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected abstract AbstractPulsarMessageToSpringMessageAdapter<K>	createReaderListener(PulsarMessageReaderContainer container, @Nullable MessageConverter messageConverter)
@Nullable Boolean	getAutoStartup()
protected @Nullable BeanExpressionContext	getBeanExpressionContext()
protected @Nullable BeanFactory	getBeanFactory()
protected @Nullable BeanResolver	getBeanResolver()
@Nullable String	getId()	Return the id of this endpoint.
protected @Nullable BeanExpressionResolver	getResolver()
org.apache.pulsar.common.schema.SchemaType	getSchemaType()	Return the schema type for this endpoint's container.
@Nullable org.apache.pulsar.client.api.MessageId	getStartMessageId()
List<String>	getTopics()	Return the topics for this endpoint's container.
void	setAutoStartup(@Nullable Boolean autoStartup)
void	setBeanFactory(BeanFactory beanFactory)
void	setId(String id)
void	setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
void	setStartMessageId(@Nullable org.apache.pulsar.client.api.MessageId startMessageId)
void	setSubscriptionName(String subscriptionName)
void	setTopics(String... topics)
void	setupListenerContainer(PulsarMessageReaderContainer listenerContainer, @Nullable MessageConverter messageConverter)	Sets up the specified message listener container with the model defined by this endpoint.

Methods inherited from class Object

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

Constructor Details

AbstractPulsarReaderEndpoint

public AbstractPulsarReaderEndpoint()

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getBeanFactory

protected @Nullable BeanFactory getBeanFactory()

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

getResolver

protected @Nullable BeanExpressionResolver getResolver()

getBeanExpressionContext

protected @Nullable BeanExpressionContext getBeanExpressionContext()

getBeanResolver

protected @Nullable BeanResolver getBeanResolver()

setSubscriptionName

public void setSubscriptionName(String subscriptionName)

setId

public void setId(String id)

getId

public @Nullable String getId()

Description copied from interface: PulsarReaderEndpoint

Return the id of this endpoint.

Specified by:

getId in interface PulsarReaderEndpoint<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:

• PulsarContainerFactory.createRegisteredContainer(E)

setTopics

public void setTopics(String... topics)

getTopics

public List<String> getTopics()

Description copied from interface: PulsarReaderEndpoint

Return the topics for this endpoint's container.

Specified by:

getTopics in interface PulsarReaderEndpoint<K>

Returns:

the topics.

getAutoStartup

public @Nullable Boolean getAutoStartup()

Specified by:

getAutoStartup in interface PulsarReaderEndpoint<K>

setAutoStartup

public void setAutoStartup(@Nullable Boolean autoStartup)

setupListenerContainer

public void setupListenerContainer(PulsarMessageReaderContainer listenerContainer,
 @Nullable MessageConverter messageConverter)

Description copied from interface: PulsarReaderEndpoint

Sets up 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 PulsarReaderEndpoint<K>

Parameters:

listenerContainer - the listener container to configure

messageConverter - message converter used

createReaderListener

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

getSchemaType

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

Description copied from interface: PulsarReaderEndpoint

Return the schema type for this endpoint's container.

Specified by:

getSchemaType in interface PulsarReaderEndpoint<K>

Returns:

the schema type.

setSchemaType

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

getStartMessageId

public @Nullable org.apache.pulsar.client.api.MessageId getStartMessageId()

Specified by:

getStartMessageId in interface PulsarReaderEndpoint<K>

setStartMessageId

public void setStartMessageId(@Nullable org.apache.pulsar.client.api.MessageId startMessageId)