Package org.springframework.pulsar.config

Class AbstractPulsarReaderContainerFactory<C extends AbstractPulsarMessageReaderContainer<T>,T>

java.lang.Object

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

Type Parameters:

C - the AbstractPulsarMessageReaderContainer implementation type.

T - Message payload type.

All Implemented Interfaces:

Aware, ApplicationContextAware, ApplicationEventPublisherAware, PulsarContainerFactory<PulsarMessageReaderContainer,PulsarReaderEndpoint<PulsarMessageReaderContainer>>, PulsarReaderContainerFactory, ReaderContainerFactory<PulsarMessageReaderContainer,PulsarReaderEndpoint<PulsarMessageReaderContainer>>

Direct Known Subclasses:

DefaultPulsarReaderContainerFactory

public abstract class AbstractPulsarReaderContainerFactory<C extends AbstractPulsarMessageReaderContainer<T>,T>
extends Object
implements PulsarReaderContainerFactory, ApplicationEventPublisherAware, ApplicationContextAware

Base PulsarReaderContainerFactory implementation.

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
protected final LogAccessor	logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPulsarReaderContainerFactory(PulsarReaderFactory<? super T> readerFactory, PulsarReaderContainerProperties containerProperties)

Method Summary

Modifier and Type	Method	Description
protected abstract C	createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
C	createRegisteredContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)	Create a message listener container for the given endpoint.
PulsarReaderContainerProperties	getContainerProperties()
protected PulsarReaderFactory<? super T>	getReaderFactory()
protected void	initializeContainer(C instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
void	setApplicationContext(ApplicationContext applicationContext)
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setAutoStartup(Boolean autoStartup)
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.PulsarContainerFactory

createContainer

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

createReaderContainer, createReaderContainer

Field Details

logger

protected final LogAccessor logger

Constructor Details

AbstractPulsarReaderContainerFactory

protected AbstractPulsarReaderContainerFactory(PulsarReaderFactory<? super T> readerFactory,
 PulsarReaderContainerProperties containerProperties)

Method Details

getReaderFactory

protected PulsarReaderFactory<? super T> getReaderFactory()

getContainerProperties

public PulsarReaderContainerProperties 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.

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

createRegisteredContainer

public C createRegisteredContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)

Description copied from interface: PulsarContainerFactory

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

Specified by:

createRegisteredContainer in interface PulsarContainerFactory<C extends AbstractPulsarMessageReaderContainer<T>,T>

Parameters:

endpoint - the endpoint to configure

Returns:

the created container

createContainerInstance

protected abstract C createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)

initializeContainer

protected void initializeContainer(C instance,
 PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)