Class DefaultPulsarMessageListenerContainer<T>
java.lang.Object
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, deadLetterPolicy, lifecycleMonitor, logger, negativeAckRedeliveryBackoff, pulsarConsumerErrorHandlerFields 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, getApplicationContext, getApplicationEventPublisher, getBeanName, getContainerProperties, getDeadLetterPolicy, getNegativeAckRedeliveryBackoff, getObservationRegistry, getPhase, getPulsarConsumerErrorHandler, getPulsarConsumerFactory, isAutoStartup, isRunning, setAckTimeoutRedeliveryBackoff, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBeanName, setDeadLetterPolicy, setNegativeAckRedeliveryBackoff, setPhase, setPulsarConsumerErrorHandler, setRunning, setupMessageListener, start, stopMethods 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
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 classAbstractPulsarMessageListenerContainer<T>
-
doStop
public void doStop()- Specified by:
doStopin classAbstractPulsarMessageListenerContainer<T>
-