qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ritch...@apache.org
Subject svn commit: r630833 - /incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQConnection.java
Date Mon, 25 Feb 2008 12:59:05 GMT
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())
                         {



Mime
View raw message