Package org.springframework.pulsar.reactive.config

Class ReactivePulsarListenerEndpointRegistry<T>

java.lang.Object
org.springframework.pulsar.config.GenericListenerEndpointRegistry<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>>
org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointRegistry<T>
Type Parameters:
T - Message payload type.
All Implemented Interfaces:
EventListener, Aware, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, Lifecycle, Phased, SmartLifecycle, PulsarListenerContainerRegistry
public class ReactivePulsarListenerEndpointRegistry<T> extends GenericListenerEndpointRegistry<ReactivePulsarMessageListenerContainer<T>,ReactivePulsarListenerEndpoint<T>>
Creates the necessary ReactivePulsarMessageListenerContainer instances for the registered endpoints. Also manages the lifecycle of the listener containers, in particular within the lifecycle of the application context.

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

Author:
Christophe Bornet

  • Constructor Details

    • ReactivePulsarListenerEndpointRegistry

      public ReactivePulsarListenerEndpointRegistry()