Removed 'autoStartup' from AbstractConsumer
This commit is contained in:
@@ -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();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user