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, 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
protected DefaultPulsarMessageReaderContainer<T>	createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)
DefaultPulsarMessageReaderContainer<T>	createReaderContainer(String... topics)
protected void	initializeContainer(DefaultPulsarMessageReaderContainer<T> instance, PulsarReaderEndpoint<PulsarMessageReaderContainer> endpoint)

Methods inherited from class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory

createReaderContainer, 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

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>

createReaderContainer

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