Package org.springframework.pulsar.config

Class PulsarListenerEndpointRegistry

java.lang.Object

org.springframework.pulsar.config.GenericListenerEndpointRegistry<PulsarMessageListenerContainer,PulsarListenerEndpoint>

org.springframework.pulsar.config.PulsarListenerEndpointRegistry

All Implemented Interfaces:

EventListener, Aware, DisposableBean, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>, Lifecycle, Phased, SmartLifecycle, PulsarListenerContainerRegistry

public class PulsarListenerEndpointRegistry
extends GenericListenerEndpointRegistry<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 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:

Soby Chacko, Christophe Bornet

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
PulsarListenerEndpointRegistry()

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

PulsarListenerEndpointRegistry

public PulsarListenerEndpointRegistry()