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<T> implements Pulsa
 	@Override
 	public void stop() {
 		synchronized (this.lifecycleMonitor) {
-			if (!isRunning()) {
+			if (isRunning()) {
 				doStop();
 			}
 		}