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 ReactivePulsarMessageListenerContainer
s 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
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
-
Method Summary
Methods inherited from class org.springframework.pulsar.config.GenericListenerEndpointRegistry
createListenerContainer, destroy, getAllListenerContainers, getListenerContainer, getListenerContainerIds, getListenerContainers, getPhase, isAutoStartup, isRunning, onApplicationEvent, registerListenerContainer, registerListenerContainer, setApplicationContext, start, stop, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.context.ApplicationListener
supportsAsyncExecution
-
Constructor Details
-
ReactivePulsarListenerEndpointRegistry
public ReactivePulsarListenerEndpointRegistry()
-