Class GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>

java.lang.Object
org.springframework.pulsar.config.GenericReaderEndpointRegistry<C,E>
Type Parameters:
C - container type
E - endpoint type
All Implemented Interfaces:
EventListener, Aware, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, Lifecycle, Phased, SmartLifecycle, PulsarReaderContainerRegistry
Direct Known Subclasses:
PulsarReaderEndpointRegistry

Creates the necessary container instances for the registered endpoints. Also manages the lifecycle of the reader containers, in particular within the lifecycle of the application context.

Contrary to containers created manually, reader listener containers managed by registry are not beans in the application context and are not candidates for autowiring. Use getReaderContainers() ()} if you need to access this registry's reader listener containers for management purposes. If you need to access to a specific reader listener container, use getReaderContainer(String) with the id of the endpoint.

Author:
Soby Chacko