You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2009/05/13 14:55:21 UTC
svn commit: r774305 -
/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
Author: rajith
Date: Wed May 13 12:55:20 2009
New Revision: 774305
URL: http://svn.apache.org/viewvc?rev=774305&view=rev
Log:
This is a fix for QPID-1854
I have added a sender.close() inside the closed() method in the Connection.java
This ensures the sender is closed and the IoSender thread is shutdown gracefully.
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
Modified: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java?rev=774305&r1=774304&r2=774305&view=diff
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java (original)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/transport/Connection.java Wed May 13 12:55:20 2009
@@ -438,6 +438,7 @@
ssn.closed();
}
+ sender.close();
sender = null;
setState(CLOSED);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org