activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r547225 - /activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h
Date Thu, 14 Jun 2007 11:53:11 GMT
Author: tabish
Date: Thu Jun 14 04:53:10 2007
New Revision: 547225

URL: http://svn.apache.org/viewvc?view=rev&rev=547225
Log:
https://issues.apache.org/activemq/browse/AMQCPP-128

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h

Modified: activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h?view=diff&rev=547225&r1=547224&r2=547225
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/transport/IOTransport.h Thu Jun 14 04:53:10
2007
@@ -116,8 +116,10 @@
 
             try{
                 // Since the listener is responsible for freeing the memory,
-                // if there is no listener - free the command here.
-                if( listener == NULL ){
+                // if there is no listener - free the command here.  Also if
+                // we have been closed then we don't deliver any messages that
+                // might have snuck in while we where closing.
+                if( listener == NULL || closed == true ){
                     delete command;
                     return;
                 }



Mime
View raw message