Package org.springframework.pulsar.config

Class GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>

java.lang.Object

org.springframework.pulsar.config.GenericReaderEndpointRegistry<C,E>

Type Parameters:

C - container type

E - endpoint type

All Implemented Interfaces:

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

Direct Known Subclasses:

PulsarReaderEndpointRegistry

public class GenericReaderEndpointRegistry<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>>
extends Object
implements PulsarReaderContainerRegistry, DisposableBean, SmartLifecycle, ApplicationContextAware, ApplicationListener<ContextRefreshedEvent>

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

Contrary to containers created manually, reader listener containers managed by registry are not beans in the application context and are not candidates for autowiring. Use getReaderContainers() ()} if you need to access this registry's reader listener containers for management purposes. If you need to access to a specific reader listener container, use 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

Modifier	Constructor	Description
protected	GenericReaderEndpointRegistry(Class<?> type)

Method Summary

Modifier and Type	Method	Description
protected C	createReaderContainer(E endpoint, ReaderContainerFactory<? extends C,E> factory)
void	destroy()
Collection<C>	getAllReaderContainers()
int	getPhase()
C	getReaderContainer(String id)
Set<String>	getReaderContainerIds()
Collection<C>	getReaderContainers()
boolean	isAutoStartup()
boolean	isRunning()
void	onApplicationEvent(ContextRefreshedEvent event)
void	registerReaderContainer(E endpoint, ReaderContainerFactory<? extends C,E> factory)
void	registerReaderContainer(E endpoint, ReaderContainerFactory<? extends C,E> factory, boolean startImmediately)
void	setApplicationContext(ApplicationContext applicationContext)
void	start()
void	stop()
void	stop(Runnable callback)

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

GenericReaderEndpointRegistry

protected GenericReaderEndpointRegistry(Class<?> type)

Method Details

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

getReaderContainer

@Nullable
public C getReaderContainer(String id)

Specified by:

getReaderContainer in interface PulsarReaderContainerRegistry

getReaderContainerIds

public Set<String> getReaderContainerIds()

Specified by:

getReaderContainerIds in interface PulsarReaderContainerRegistry

getReaderContainers

public Collection<C> getReaderContainers()

Specified by:

getReaderContainers in interface PulsarReaderContainerRegistry

getAllReaderContainers

public Collection<C> getAllReaderContainers()

Specified by:

getAllReaderContainers in interface PulsarReaderContainerRegistry

registerReaderContainer

public void registerReaderContainer(E endpoint,
 ReaderContainerFactory<? extends C,E> factory)

registerReaderContainer

public void registerReaderContainer(E endpoint,
 ReaderContainerFactory<? extends C,E> factory,
 boolean startImmediately)

createReaderContainer

protected C createReaderContainer(E endpoint,
 ReaderContainerFactory<? extends C,E> factory)

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

onApplicationEvent

public void onApplicationEvent(ContextRefreshedEvent event)

Specified by:

onApplicationEvent in interface ApplicationListener<C extends PulsarMessageReaderContainer>