|
|
@ -128,10 +128,13 @@ public abstract class AbstractBrokerMessageHandler |
|
|
|
public final void start() { |
|
|
|
public final void start() { |
|
|
|
synchronized (this.lifecycleMonitor) { |
|
|
|
synchronized (this.lifecycleMonitor) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
logger.debug("Starting " + getClass().getSimpleName()); |
|
|
|
logger.debug("Starting"); |
|
|
|
} |
|
|
|
} |
|
|
|
startInternal(); |
|
|
|
startInternal(); |
|
|
|
this.running = true; |
|
|
|
this.running = true; |
|
|
|
|
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
|
|
|
|
logger.debug("Started"); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -142,10 +145,13 @@ public abstract class AbstractBrokerMessageHandler |
|
|
|
public final void stop() { |
|
|
|
public final void stop() { |
|
|
|
synchronized (this.lifecycleMonitor) { |
|
|
|
synchronized (this.lifecycleMonitor) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
logger.debug("Stopping " + getClass().getSimpleName()); |
|
|
|
logger.debug("Stopping"); |
|
|
|
} |
|
|
|
} |
|
|
|
stopInternal(); |
|
|
|
stopInternal(); |
|
|
|
this.running = false; |
|
|
|
this.running = false; |
|
|
|
|
|
|
|
if (logger.isDebugEnabled()) { |
|
|
|
|
|
|
|
logger.debug("Stopped"); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|