Fix a bug in the way containers are stopped

2022-09-02 17:48:58 -04:00
parent 07dc259665
commit f590a6d70e
1 changed files with 1 additions and 1 deletions
--- 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<T> implements Pulsa
 	@Override
 	public void stop() {
 		synchronized (this.lifecycleMonitor) {
-			if (!isRunning()) {
+			if (isRunning()) {
 				doStop();
 			}
 		}