Package org.springframework.pulsar.config

Class DefaultPulsarReaderContainerFactory<T>

java.lang.Object

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

org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory<T>

Type Parameters:

T - message type in the listener.

All Implemented Interfaces:

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

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

Concrete implementation for PulsarReaderContainerFactory.

Author:

Soby Chacko

Field Summary

Fields inherited from class org.springframework.pulsar.config.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 org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory

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

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.ReaderContainerFactory

createReaderContainer, createReaderContainer

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.