Package org.springframework.pulsar.core

Class AbstractPulsarMessageContainer

java.lang.Object

org.springframework.pulsar.core.AbstractPulsarMessageContainer

All Implemented Interfaces:

Aware, BeanNameAware, DisposableBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

AbstractPulsarMessageListenerContainer, AbstractPulsarMessageReaderContainer

public abstract class AbstractPulsarMessageContainer
extends Object
implements ApplicationEventPublisherAware, BeanNameAware, ApplicationContextAware, SmartLifecycle, DisposableBean

Base class for the various container implementations.

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	autoStartup
protected final LogAccessor	logger
protected boolean	running

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
AbstractPulsarMessageContainer()

Method Summary

Modifier and Type	Method	Description
protected abstract void	doStart()
protected abstract void	doStop()
protected ApplicationContext	getApplicationContext()
ApplicationEventPublisher	getApplicationEventPublisher()	Get the event publisher.
String	getBeanName()	Return the bean name.
int	getPhase()
void	setApplicationContext(ApplicationContext applicationContext)
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setBeanName(String name)
void	setPhase(int phase)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Methods inherited from interface org.springframework.context.Lifecycle

isRunning, start, stop

Methods inherited from interface org.springframework.context.SmartLifecycle

isAutoStartup, stop

Field Details

logger

protected final LogAccessor logger

autoStartup

protected boolean autoStartup

running

protected volatile boolean running

Constructor Details

AbstractPulsarMessageContainer

public AbstractPulsarMessageContainer()

Method Details

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

getApplicationEventPublisher

@Nullable
public ApplicationEventPublisher getApplicationEventPublisher()

Get the event publisher.

Returns:

the publisher

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

getBeanName

@Nullable
public String getBeanName()

Return the bean name.

Returns:

the bean name.

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

getApplicationContext

@Nullable
protected ApplicationContext getApplicationContext()

setPhase

public void setPhase(int phase)

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

doStart

protected abstract void doStart()

doStop

protected abstract void doStop()