diff --git a/spring-eai-core/src/main/java/org/springframework/integration/channel/consumer/AbstractConsumer.java b/spring-eai-core/src/main/java/org/springframework/integration/channel/consumer/AbstractConsumer.java index a93bf64fe0..b79ddeda07 100644 --- a/spring-eai-core/src/main/java/org/springframework/integration/channel/consumer/AbstractConsumer.java +++ b/spring-eai-core/src/main/java/org/springframework/integration/channel/consumer/AbstractConsumer.java @@ -50,8 +50,6 @@ public abstract class AbstractConsumer implements Lifecycle { private boolean running = false; - private boolean autoStartup = true; - protected final Object lifecycleMonitor = new Object(); @@ -67,10 +65,6 @@ public abstract class AbstractConsumer implements Lifecycle { this.receiveTimeout = receiveTimeout; } - public void setAutoStartup(boolean autoStartup) { - this.autoStartup = autoStartup; - } - public final boolean isRunning() { synchronized (this.lifecycleMonitor) { return this.running; @@ -105,11 +99,6 @@ public abstract class AbstractConsumer implements Lifecycle { this.lifecycleMonitor.notifyAll(); } doInitialize(); - if (this.autoStartup) { - synchronized (this.lifecycleMonitor) { - this.start(); - } - } } /**