Package org.springframework.pulsar.reader

Class DefaultPulsarMessageReaderContainer<T>

java.lang.Object

org.springframework.pulsar.core.AbstractPulsarMessageContainer

org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer<T>

org.springframework.pulsar.reader.DefaultPulsarMessageReaderContainer<T>

Type Parameters:

T - reader data type.

All Implemented Interfaces:

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

public class DefaultPulsarMessageReaderContainer<T>
extends AbstractPulsarMessageReaderContainer<T>

Default implementation for the Pulsar reader container. This implementation is responsible for all the lifecycle management for the reader container.

Author:

Soby Chacko

Field Summary

Fields inherited from class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer

lifecycleLock, readerBuilderCustomizer

Fields inherited from class org.springframework.pulsar.core.AbstractPulsarMessageContainer

autoStartup, logger, running

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarMessageReaderContainer(PulsarReaderFactory<? super T> pulsarReaderFactory, PulsarReaderContainerProperties pulsarReaderContainerProperties)

Method Summary

Modifier and Type	Method	Description
protected void	doStart()
protected void	doStop()

Methods inherited from class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer

getContainerProperties, getPulsarReaderFactory, getReaderBuilderCustomizer, isAutoStartup, isRunning, setAutoStartup, setReaderCustomizer, setRunning, setupReaderListener, start, stop

Methods inherited from class org.springframework.pulsar.core.AbstractPulsarMessageContainer

getApplicationContext, getApplicationEventPublisher, getBeanName, getPhase, setApplicationContext, setApplicationEventPublisher, setBeanName, setPhase

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.pulsar.reader.PulsarMessageReaderContainer

destroy

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, stop

Constructor Details

DefaultPulsarMessageReaderContainer

public DefaultPulsarMessageReaderContainer(PulsarReaderFactory<? super T> pulsarReaderFactory,
 PulsarReaderContainerProperties pulsarReaderContainerProperties)

Method Details

doStart

protected void doStart()

Specified by:

doStart in class AbstractPulsarMessageContainer

doStop

protected void doStop()

Specified by:

doStop in class AbstractPulsarMessageContainer