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
ConstructorDescriptionDefaultPulsarMessageListenerContainer
(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties) -
Method Summary
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 classAbstractPulsarMessageContainer
-
doStop
public void doStop()- Specified by:
doStop
in classAbstractPulsarMessageContainer
-
doPause
public void doPause()- Specified by:
doPause
in classAbstractPulsarMessageListenerContainer<T>
-
doResume
public void doResume()- Specified by:
doResume
in classAbstractPulsarMessageListenerContainer<T>
-