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, lifecycleMonitor, negativeAckRedeliveryBackoff, pulsarConsumerErrorHandlerFields inherited from class org.springframework.pulsar.core.AbstractPulsarMessageContainer
autoStartup, logger, runningFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionDefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties) DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) -
Method Summary
Methods inherited from class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
getAckTimeoutkRedeliveryBackoff, getConsumerBuilderCustomizer, getContainerProperties, getDeadLetterPolicy, getNegativeAckRedeliveryBackoff, getObservationRegistry, getPulsarConsumerErrorHandler, getPulsarConsumerFactory, isAutoStartup, isPaused, isRunning, pause, resume, setAckTimeoutRedeliveryBackoff, setAutoStartup, setConsumerCustomizer, setDeadLetterPolicy, setNegativeAckRedeliveryBackoff, setPaused, setPulsarConsumerErrorHandler, setRunning, setupMessageListener, start, stopMethods inherited from class org.springframework.pulsar.core.AbstractPulsarMessageContainer
getApplicationContext, getApplicationEventPublisher, getBeanName, getPhase, setApplicationContext, setApplicationEventPublisher, setBeanName, setPhaseMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.pulsar.listener.MessageListenerContainer
destroyMethods inherited from interface org.springframework.context.SmartLifecycle
getPhase, stop
-
Constructor Details
-
DefaultPulsarMessageListenerContainer
public DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties) -
DefaultPulsarMessageListenerContainer
public DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties, @Nullable io.micrometer.observation.ObservationRegistry observationRegistry)
-
-
Method Details
-
doStart
protected void doStart()- Specified by:
doStartin classAbstractPulsarMessageContainer
-
doStop
public void doStop()- Specified by:
doStopin classAbstractPulsarMessageContainer
-
doPause
public void doPause()- Specified by:
doPausein classAbstractPulsarMessageListenerContainer<T>
-
doResume
public void doResume()- Specified by:
doResumein classAbstractPulsarMessageListenerContainer<T>
-