Author: kwall
Date: Sat Feb 14 08:55:10 2015
New Revision: 1659763
URL: http://svn.apache.org/r1659763
Log:
QPID-6393: [Java Broker] Prevent possibility for the permature close of queue
browser
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java?rev=1659763&r1=1659762&r2=1659763&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
(original)
+++
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AbstractQueue.java
Sat Feb 14 08:55:10 2015
@@ -2160,7 +2160,7 @@ public abstract class AbstractQueue<X ex
if (consumerDone)
{
sub.flushBatched();
- if (lastLoop && !sub.isSuspended())
+ if (lastLoop && getNextAvailableEntry(sub) ==
null)
{
sub.queueEmpty();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
