Class DefaultReactivePulsarMessageListenerContainer<T>
java.lang.Object
org.springframework.pulsar.reactive.listener.DefaultReactivePulsarMessageListenerContainer<T>
- Type Parameters:
T- message type.
- All Implemented Interfaces:
DisposableBean,Lifecycle,Phased,SmartLifecycle,MessageListenerContainer,ReactivePulsarMessageListenerContainer<T>
public non-sealed class DefaultReactivePulsarMessageListenerContainer<T>
extends Object
implements ReactivePulsarMessageListenerContainer<T>
Default implementation for
ReactivePulsarMessageListenerContainer.- Author:
- Christophe Bornet
-
Field Summary
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionDefaultReactivePulsarMessageListenerContainer(ReactivePulsarConsumerFactory<T> pulsarConsumerFactory, ReactivePulsarContainerProperties<T> pulsarContainerProperties) -
Method Summary
Modifier and TypeMethodDescriptionvoiddoStop()booleanbooleanvoidsetAutoStartup(boolean autoStartup) voidsetConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) protected voidsetRunning(boolean running) voidsetupMessageHandler(ReactivePulsarMessageHandler messageHandler) final voidstart()voidstop()Methods 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
-
DefaultReactivePulsarMessageListenerContainer
public DefaultReactivePulsarMessageListenerContainer(ReactivePulsarConsumerFactory<T> pulsarConsumerFactory, ReactivePulsarContainerProperties<T> pulsarContainerProperties)
-
-
Method Details
-
getReactivePulsarConsumerFactory
-
getContainerProperties
- Specified by:
getContainerPropertiesin interfaceReactivePulsarMessageListenerContainer<T>
-
isRunning
public boolean isRunning() -
setRunning
protected void setRunning(boolean running) -
setupMessageHandler
- Specified by:
setupMessageHandlerin interfaceReactivePulsarMessageListenerContainer<T>
-
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceSmartLifecycle
-
setAutoStartup
public void setAutoStartup(boolean autoStartup) - Specified by:
setAutoStartupin interfaceMessageListenerContainer
-
getConsumerCustomizer
-
setConsumerCustomizer
- Specified by:
setConsumerCustomizerin interfaceReactivePulsarMessageListenerContainer<T>
-
start
public final void start() -
stop
public void stop() -
doStop
public void doStop()
-