Author: ritchiem
Date: Mon Feb 25 04:59:03 2008
New Revision: 630833
URL: http://svn.apache.org/viewvc?rev=630833&view=rev
Log:
QPID-811 : The RejectionEE is occuring because the task pool is shutdown before
the close-ok has been received.
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Modified:
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java?rev=630833&r1=630832&r2=630833&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
(original)
+++
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Mon Feb 25 04:59:03 2008
@@ -927,8 +927,10 @@
{
long startCloseTime = System.currentTimeMillis();
- _taskPool.shutdown();
closeAllSessions(null, timeout, startCloseTime);
+
+ //This MUST occur after we have successfully closed
all Channels/Sessions
+ _taskPool.shutdown();
if (!_taskPool.isTerminated())
{
