Package org.springframework.pulsar.config

Class AbstractPulsarReaderEndpoint<K>

java.lang.Object

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

Type Parameters:

K - Message payload type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, PulsarReaderEndpoint<PulsarMessageReaderContainer>

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, MessageConverter messageConverter)
Boolean	getAutoStartup()
protected BeanExpressionContext	getBeanExpressionContext()
protected BeanFactory	getBeanFactory()
protected BeanResolver	getBeanResolver()
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.
org.apache.pulsar.client.api.MessageId	getStartMessageId()
List<String>	getTopics()	Return the topics for this endpoint's container.
void	setAutoStartup(Boolean autoStartup)
void	setBeanFactory(BeanFactory beanFactory)
void	setId(String id)
void	setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
void	setStartMessageId(org.apache.pulsar.client.api.MessageId startMessageId)
void	setSubscriptionName(String subscriptionName)
void	setTopics(String... topics)
void	setupListenerContainer(PulsarMessageReaderContainer 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

AbstractPulsarReaderEndpoint

public AbstractPulsarReaderEndpoint()

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)

setId

public void setId(String id)

getId

public 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

@Nullable
public Boolean getAutoStartup()

Specified by:

getAutoStartup in interface PulsarReaderEndpoint<K>

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setupListenerContainer

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

Description copied from interface: PulsarReaderEndpoint

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 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 org.apache.pulsar.client.api.MessageId getStartMessageId()

Specified by:

getStartMessageId in interface PulsarReaderEndpoint<K>

setStartMessageId

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