mirror of https://github.com/apache/activemq.git
don't iterate through dispatchQueue if the broker is stopped
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390614 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
68cd5ea517
commit
a748040d31
|
@ -577,7 +577,7 @@ public abstract class AbstractConnection implements Service, Connection, Task, C
|
|||
}
|
||||
|
||||
public boolean iterate() {
|
||||
if( dispatchQueue.isEmpty() ) {
|
||||
if( dispatchQueue.isEmpty() || broker.isStopped()) {
|
||||
return false;
|
||||
} else {
|
||||
Command command = (Command) dispatchQueue.remove(0);
|
||||
|
|
Loading…
Reference in New Issue