Class AbstractPulsarMessageReaderContainer<T>

java.lang.Object

org.apache.pulsar.spring.core.AbstractPulsarMessageContainer

org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer<T>

Type Parameters:

T - reader data type.

All Implemented Interfaces:

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

Direct Known Subclasses:

DefaultPulsarMessageReaderContainer

public abstract non-sealed class AbstractPulsarMessageReaderContainer<T>
extends AbstractPulsarMessageContainer
implements PulsarMessageReaderContainer

Core implementation for PulsarMessageReaderContainer.

Author:

Soby Chacko

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReentrantLock	lifecycleLock
protected @Nullable ReaderBuilderCustomizer<T>	readerBuilderCustomizer

Fields inherited from class AbstractPulsarMessageContainer

autoStartup, logger, running

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractPulsarMessageReaderContainer(PulsarReaderFactory<? super T> pulsarReaderFactory, PulsarReaderContainerProperties pulsarReaderContainerProperties)

Method Summary

Modifier and Type	Method	Description
PulsarReaderContainerProperties	getContainerProperties()
PulsarReaderFactory<T>	getPulsarReaderFactory()
@Nullable ReaderBuilderCustomizer<T>	getReaderBuilderCustomizer()
boolean	isAutoStartup()
boolean	isRunning()
void	setAutoStartup(boolean autoStartup)
void	setReaderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)	Set a reader customizer on this container.
protected void	setRunning(boolean running)
void	setupReaderListener(Object messageListener)
final void	start()
void	stop()

Methods inherited from class AbstractPulsarMessageContainer

doStart, doStop, getApplicationContext, getApplicationEventPublisher, getBeanName, getPhase, requireNonNullBeanName, setApplicationContext, setApplicationEventPublisher, setBeanName, setPhase

Methods inherited from class Object

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

Methods inherited from interface PulsarMessageReaderContainer

destroy

Methods inherited from interface SmartLifecycle

getPhase, isPauseable, stop

Field Details

lifecycleLock

protected final ReentrantLock lifecycleLock

readerBuilderCustomizer

protected @Nullable ReaderBuilderCustomizer<T> readerBuilderCustomizer

Constructor Details

AbstractPulsarMessageReaderContainer

protected AbstractPulsarMessageReaderContainer(PulsarReaderFactory<? super T> pulsarReaderFactory,
 PulsarReaderContainerProperties pulsarReaderContainerProperties)

Method Details

getPulsarReaderFactory

public PulsarReaderFactory<T> getPulsarReaderFactory()

getContainerProperties

public PulsarReaderContainerProperties getContainerProperties()

Specified by:

getContainerProperties in interface PulsarMessageReaderContainer

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

setRunning

protected void setRunning(boolean running)

setupReaderListener

public void setupReaderListener(Object messageListener)

Specified by:

setupReaderListener in interface PulsarMessageReaderContainer

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

setAutoStartup

public void setAutoStartup(boolean autoStartup)

Specified by:

setAutoStartup in interface PulsarMessageReaderContainer

start

public final void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

setReaderCustomizer

public void setReaderCustomizer(ReaderBuilderCustomizer<?> readerBuilderCustomizer)

Description copied from interface: PulsarMessageReaderContainer

Set a reader customizer on this container.

Specified by:

setReaderCustomizer in interface PulsarMessageReaderContainer

Parameters:

readerBuilderCustomizer - ReaderBuilderCustomizer

getReaderBuilderCustomizer

public @Nullable ReaderBuilderCustomizer<T> getReaderBuilderCustomizer()