Class DefaultPulsarReaderContainerFactory<T>

java.lang.Object

org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory<DefaultPulsarMessageReaderContainer<T>, T>

org.apache.pulsar.spring.config.DefaultPulsarReaderContainerFactory<T>

Type Parameters:

T - message type in the listener.

All Implemented Interfaces:

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

public class DefaultPulsarReaderContainerFactory<T>
extends AbstractPulsarReaderContainerFactory<DefaultPulsarMessageReaderContainer<T>, T>

Concrete implementation for PulsarReaderContainerFactory.

Author:

Soby Chacko

Field Summary

Fields inherited from class AbstractPulsarReaderContainerFactory

logger

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarReaderContainerFactory(PulsarReaderFactory<? super T> readerFactory, PulsarReaderContainerProperties containerProperties)

Method Summary

Modifier and Type	Method	Description
DefaultPulsarMessageReaderContainer<T>	createContainer(String... topics)	Create and configure a container without a listener.
protected DefaultPulsarMessageReaderContainer<T>	createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
protected void	initializeContainer(DefaultPulsarMessageReaderContainer<T> instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)

Methods inherited from class AbstractPulsarReaderContainerFactory

createRegisteredContainer, getContainerProperties, getReaderFactory, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setMessageConverter, setPhase

Methods inherited from class Object

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

Constructor Details

DefaultPulsarReaderContainerFactory

public DefaultPulsarReaderContainerFactory(PulsarReaderFactory<? super T> readerFactory,
 PulsarReaderContainerProperties containerProperties)

Method Details

createContainerInstance

protected DefaultPulsarMessageReaderContainer<T> createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)

Specified by:

createContainerInstance in class AbstractPulsarReaderContainerFactory<DefaultPulsarMessageReaderContainer<T>, T>

initializeContainer

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

Overrides:

initializeContainer in class AbstractPulsarReaderContainerFactory<DefaultPulsarMessageReaderContainer<T>, T>

createContainer

public DefaultPulsarMessageReaderContainer<T> createContainer(String... topics)

Description copied from interface: PulsarContainerFactory

Create and configure a container without a listener. Containers created using this method are not added to the listener endpoint registry.

Parameters:

topics - the topics.

Returns:

the container.