Package org.springframework.pulsar.config

Class AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>

java.lang.Object

org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory<C,T>

Type Parameters:

C - the AbstractPulsarMessageListenerContainer implementation type.

T - Message payload type.

All Implemented Interfaces:

Aware, ApplicationContextAware, ApplicationEventPublisherAware, ListenerContainerFactory<PulsarMessageListenerContainer,PulsarListenerEndpoint>, PulsarListenerContainerFactory

Direct Known Subclasses:

ConcurrentPulsarListenerContainerFactory

public abstract class AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>
extends Object
implements PulsarListenerContainerFactory, ApplicationEventPublisherAware, ApplicationContextAware

Base PulsarListenerContainerFactory implementation.

Author:

Soby Chacko, Chris Bono

Field Summary

Fields

Modifier and Type	Field	Description
protected final LogAccessor	logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory, PulsarContainerProperties containerProperties)

Method Summary

Modifier and Type	Method	Description
protected abstract C	createContainerInstance(PulsarListenerEndpoint endpoint)
C	createListenerContainer(PulsarListenerEndpoint endpoint)	Create a MessageListenerContainer for the given ListenerEndpoint.
protected PulsarConsumerFactory<? super T>	getConsumerFactory()
PulsarContainerProperties	getContainerProperties()
protected void	initializeContainer(C instance, PulsarListenerEndpoint endpoint)
void	setApplicationContext(ApplicationContext applicationContext)
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setAutoStartup(Boolean autoStartup)
void	setBatchListener(Boolean batchListener)
void	setMessageConverter(MessageConverter messageConverter)	Set the message converter to use if dynamic argument type matching is needed.
void	setPhase(int phase)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.pulsar.config.ListenerContainerFactory

createContainer

Field Details

logger

protected final LogAccessor logger

Constructor Details

AbstractPulsarListenerContainerFactory

protected AbstractPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory,
 PulsarContainerProperties containerProperties)

Method Details

getConsumerFactory

protected PulsarConsumerFactory<? super T> getConsumerFactory()

getContainerProperties

public PulsarContainerProperties getContainerProperties()

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

setAutoStartup

public void setAutoStartup(Boolean autoStartup)

setPhase

public void setPhase(int phase)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Set the message converter to use if dynamic argument type matching is needed.

Parameters:

messageConverter - the converter.

setBatchListener

public void setBatchListener(Boolean batchListener)

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

createListenerContainer

public C createListenerContainer(PulsarListenerEndpoint endpoint)

Description copied from interface: ListenerContainerFactory

Create a MessageListenerContainer for the given ListenerEndpoint. Containers created using this method are added to the listener endpoint registry.

Specified by:

createListenerContainer in interface ListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T>

Parameters:

endpoint - the endpoint to configure

Returns:

the created container

createContainerInstance

protected abstract C createContainerInstance(PulsarListenerEndpoint endpoint)

initializeContainer

protected void initializeContainer(C instance,
 PulsarListenerEndpoint endpoint)