Author: kwall
Date: Sun Mar 25 00:15:43 2012
New Revision: 1304970
URL: http://svn.apache.org/viewvc?rev=1304970&view=rev
Log:
QPID-3905: NullPointerException is thrown on rejecting messages whilst closing
the connection
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=1304970&r1=1304969&r2=1304970&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 25 00:15:43 2012
@@ -3214,11 +3214,11 @@ public abstract class AMQSession<C exten
{
synchronized (_lock)
{
- boolean stopped = _dispatcher.connectionStopped();
+ boolean stopped = connectionStopped();
if (!stopped)
{
- _dispatcher.setConnectionStopped(true);
+ setConnectionStopped(true);
}
// Reject messages on pre-receive queue
@@ -3231,7 +3231,7 @@ public abstract class AMQSession<C exten
// closeConsumer
consumer.markClosed();
- _dispatcher.setConnectionStopped(stopped);
+ setConnectionStopped(stopped);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
