activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r605518 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Date Wed, 19 Dec 2007 11:49:16 GMT
Author: rajdavies
Date: Wed Dec 19 03:49:15 2007
New Revision: 605518

URL: http://svn.apache.org/viewvc?rev=605518&view=rev
Log:
ConnectionClosed exceptions being thrown in a regular connection close
removed the isClosing() check before sending async

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=605518&r1=605517&r2=605518&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
Wed Dec 19 03:49:15 2007
@@ -1144,7 +1144,7 @@
      * @throws JMSException
      */
     public void asyncSendPacket(Command command) throws JMSException {
-        if (isClosed() || closing.get()) {
+        if (isClosed()) {
             throw new ConnectionClosedException();
         } else {
             doAsyncSendPacket(command);



Mime
View raw message