Class AbstractPulsarReaderEndpoint<K>

java.lang.Object
org.springframework.pulsar.config.AbstractPulsarReaderEndpoint<K>
Type Parameters:
K - Message payload type.
All Implemented Interfaces:
Aware, BeanFactoryAware, InitializingBean, PulsarReaderEndpoint<PulsarMessageReaderContainer>
Direct Known Subclasses:
MethodPulsarReaderEndpoint

public abstract class AbstractPulsarReaderEndpoint<K> extends Object implements PulsarReaderEndpoint<PulsarMessageReaderContainer>, BeanFactoryAware, InitializingBean
Base implementation for PulsarListenerEndpoint.
Author:
Soby Chacko