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