Author: kwall
Date: Sun Mar 11 19:01:48 2012
New Revision: 1299426
URL: http://svn.apache.org/viewvc?rev=1299426&view=rev
Log:
QPID-3879: Session#close() on session can produce spurious "dispatcher is not
started" messages at ERROR to client logs
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=1299426&r1=1299425&r2=1299426&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Sun Mar 11 19:01:48 2012
@@ -3330,7 +3330,7 @@ public abstract class AMQSession<C exten
try
{
Dispatchable disp;
- while (!_closed.get() && ((disp = (Dispatchable)
_queue.take()) != null))
+ while (((disp = (Dispatchable) _queue.take()) != null) &&
!_closed.get())
{
disp.dispatch(AMQSession.this);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
