Package org.springframework.pulsar.config

Class PulsarReaderEndpointRegistry

java.lang.Object

org.springframework.pulsar.config.GenericReaderEndpointRegistry<PulsarMessageReaderContainer,PulsarReaderEndpoint<PulsarMessageReaderContainer>>

org.springframework.pulsar.config.PulsarReaderEndpointRegistry

All Implemented Interfaces:

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

public class PulsarReaderEndpointRegistry
extends GenericReaderEndpointRegistry<PulsarMessageReaderContainer,PulsarReaderEndpoint<PulsarMessageReaderContainer>>

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

Contrary to PulsarMessageReaderContainers created manually, listener containers managed by registry are not beans in the application context and are not candidates for autowiring. Use GenericReaderEndpointRegistry.getReaderContainer(String) ()} 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 GenericReaderEndpointRegistry.getReaderContainer(String) with the id of the endpoint.

Author:

Soby Chacko

Field Summary

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
PulsarReaderEndpointRegistry()

Method Summary

Methods inherited from class org.springframework.pulsar.config.GenericReaderEndpointRegistry

createReaderContainer, destroy, getAllReaderContainers, getPhase, getReaderContainer, getReaderContainerIds, getReaderContainers, isAutoStartup, isRunning, onApplicationEvent, registerReaderContainer, registerReaderContainer, 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

PulsarReaderEndpointRegistry

public PulsarReaderEndpointRegistry()