Class PulsarListenerEndpointRegistry
java.lang.Object
org.springframework.pulsar.config.ListenerEndpointRegistry<PulsarMessageListenerContainer,PulsarListenerEndpoint>
org.springframework.pulsar.config.PulsarListenerEndpointRegistry
- All Implemented Interfaces:
EventListener,Aware,DisposableBean,ApplicationContextAware,ApplicationListener<ContextRefreshedEvent>,Lifecycle,Phased,SmartLifecycle,ListenerContainerRegistry
public class PulsarListenerEndpointRegistry
extends ListenerEndpointRegistry<PulsarMessageListenerContainer,PulsarListenerEndpoint>
Creates the necessary
PulsarMessageListenerContainer instances for the
registered endpoints. Also manages the lifecycle of
the listener containers, in particular within the lifecycle of the application context.
Contrary to PulsarMessageListenerContainers created manually, listener
containers managed by registry are not beans in the application context and are not
candidates for autowiring. Use ListenerEndpointRegistry.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 ListenerEndpointRegistry.getListenerContainer(String) with the
id of the endpoint.
- Author:
- Soby Chacko, Christophe Bornet
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class org.springframework.pulsar.config.ListenerEndpointRegistry
createListenerContainer, destroy, getAllListenerContainers, getListenerContainer, getListenerContainerIds, getListenerContainers, getPhase, isAutoStartup, isRunning, onApplicationEvent, registerListenerContainer, registerListenerContainer, setApplicationContext, start, stop, stop
-
Constructor Details
-
PulsarListenerEndpointRegistry
public PulsarListenerEndpointRegistry()
-