From f590a6d70e16a857865136bca8b35570e861384b Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Fri, 2 Sep 2022 17:48:58 -0400 Subject: [PATCH] Fix a bug in the way containers are stopped --- .../pulsar/listener/AbstractPulsarMessageListenerContainer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/AbstractPulsarMessageListenerContainer.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/AbstractPulsarMessageListenerContainer.java index 5fc3b915..1d3d0250 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/AbstractPulsarMessageListenerContainer.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/AbstractPulsarMessageListenerContainer.java @@ -167,7 +167,7 @@ public abstract class AbstractPulsarMessageListenerContainer implements Pulsa @Override public void stop() { synchronized (this.lifecycleMonitor) { - if (!isRunning()) { + if (isRunning()) { doStop(); } }