activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r506119 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Date Sun, 11 Feb 2007 20:25:37 GMT
Author: tabish
Date: Sun Feb 11 12:25:37 2007
New Revision: 506119

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

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp?view=diff&rev=506119&r1=506118&r2=506119
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Sun Feb 11 12:25:37 2007
@@ -697,6 +697,8 @@
 //                consumer.Dispatch(message);
 //            }
 
+            delete command;
+
         } else if( brokerWireFormatInfo != NULL ) {
             this->brokerWireFormatInfo = brokerWireFormatInfo;
         } else if( brokerInfo != NULL ) {
@@ -710,13 +712,14 @@
                     "OpenWireConnector::onCommand - "
                     "Broker closed this connection."));
             }
+
+            delete command;
         }
         else
         {
             //LOGCMS_WARN( logger, "Received an unknown command" );
+            delete command;
         }
-
-        delete command;
     }
     AMQ_CATCH_RETHROW( ConnectorException )
     AMQ_CATCHALL_THROW( ConnectorException );



Mime
View raw message