Package org.springframework.pulsar.listener

Class DefaultPulsarMessageListenerContainer<T>

java.lang.Object

org.springframework.pulsar.core.AbstractPulsarMessageContainer

org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer<T>

org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer<T>

Type Parameters:

T - message type.

All Implemented Interfaces:

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

public class DefaultPulsarMessageListenerContainer<T>
extends AbstractPulsarMessageListenerContainer<T>

Default implementation for PulsarMessageListenerContainer.

Author:

Soby Chacko, Alexander Preuß, Chris Bono, Christophe Bornet

Field Summary

Fields inherited from class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

ackTimeoutRedeliveryBackoff, consumerBuilderCustomizer, deadLetterPolicy, lifecycleLock, negativeAckRedeliveryBackoff, pulsarConsumerErrorHandler

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
DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties)

Method Summary

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

Methods inherited from class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

getAckTimeoutkRedeliveryBackoff, getConsumerBuilderCustomizer, getContainerProperties, getDeadLetterPolicy, getNegativeAckRedeliveryBackoff, getPulsarConsumerErrorHandler, getPulsarConsumerFactory, isAutoStartup, isPaused, isRunning, pause, resume, setAckTimeoutRedeliveryBackoff, setAutoStartup, setConsumerCustomizer, setDeadLetterPolicy, setNegativeAckRedeliveryBackoff, setPaused, setPulsarConsumerErrorHandler, setRunning, setupMessageListener, 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.listener.MessageListenerContainer

destroy

Methods inherited from interface org.springframework.context.SmartLifecycle

getPhase, stop

Constructor Details

DefaultPulsarMessageListenerContainer

public DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory,
 PulsarContainerProperties pulsarContainerProperties)

Method Details

doStart

protected void doStart()

Specified by:

doStart in class AbstractPulsarMessageContainer

doStop

public void doStop()

Specified by:

doStop in class AbstractPulsarMessageContainer

doPause

public void doPause()

Specified by:

doPause in class AbstractPulsarMessageListenerContainer<T>

doResume

public void doResume()

Specified by:

doResume in class AbstractPulsarMessageListenerContainer<T>