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 TypeMethodDescriptionvoid
doStop()
boolean
boolean
void
setAutoStartup
(boolean autoStartup) void
setConsumerCustomizer
(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) protected void
setRunning
(boolean running) void
setupMessageHandler
(ReactivePulsarMessageHandler messageHandler) final void
start()
void
stop()
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
-
DefaultReactivePulsarMessageListenerContainer
public DefaultReactivePulsarMessageListenerContainer(ReactivePulsarConsumerFactory<T> pulsarConsumerFactory, ReactivePulsarContainerProperties<T> pulsarContainerProperties)
-
-
Method Details
-
getReactivePulsarConsumerFactory
-
getContainerProperties
- Specified by:
getContainerProperties
in interfaceReactivePulsarMessageListenerContainer<T>
-
isRunning
public boolean isRunning() -
setRunning
protected void setRunning(boolean running) -
setupMessageHandler
- Specified by:
setupMessageHandler
in interfaceReactivePulsarMessageListenerContainer<T>
-
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartup
in interfaceSmartLifecycle
-
setAutoStartup
public void setAutoStartup(boolean autoStartup) - Specified by:
setAutoStartup
in interfaceMessageListenerContainer
-
getConsumerCustomizer
-
setConsumerCustomizer
- Specified by:
setConsumerCustomizer
in interfaceReactivePulsarMessageListenerContainer<T>
-
start
public final void start() -
stop
public void stop() -
doStop
public void doStop()
-