svn commit: r740975 - in /activemq/activemq-cpp/trunk/src: main/activemq/core/ActiveMQConnection.cpp test/testRegistry.cpp

[tabish]

Author: tabish
Date: Thu Feb  5 01:51:25 2009
New Revision: 740975

URL: http://svn.apache.org/viewvc?rev=740975&view=rev
Log:
Fix some memory leaks

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnection.cpp
    activemq/activemq-cpp/trunk/src/test/testRegistry.cpp

Modified: 
activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnection.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnection.cpp?rev=740975&r1=740974&r2=740975&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnection.cpp 
(original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/core/ActiveMQConnection.cpp 
Thu Feb  5 01:51:25 2009
@@ -477,7 +477,6 @@
             // the appropriate time, which depends on things like
             // the session being transacted etc.
             dispatch->setMessage( NULL );
-            dispatch->setConsumerId( NULL );
 
             delete command;
 

Modified: activemq/activemq-cpp/trunk/src/test/testRegistry.cpp
URL: 
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/testRegistry.cpp?rev=740975&r1=740974&r2=740975&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/testRegistry.cpp (original)
+++ activemq/activemq-cpp/trunk/src/test/testRegistry.cpp Thu Feb  5 01:51:25 
2009
@@ -71,11 +71,11 @@
 
 #include <activemq/core/ActiveMQConnectionFactoryTest.h>
 CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionFactoryTest 
);
-//#include <activemq/core/ActiveMQConnectionTest.h>
-//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest );
-//#include <activemq/core/ActiveMQSessionTest.h>
-//CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest );
-//
+#include <activemq/core/ActiveMQConnectionTest.h>
+CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQConnectionTest );
+#include <activemq/core/ActiveMQSessionTest.h>
+CPPUNIT_TEST_SUITE_REGISTRATION( activemq::core::ActiveMQSessionTest );
+
 //#include <activemq/transport/correlator/ResponseCorrelatorTest.h>
 //CPPUNIT_TEST_SUITE_REGISTRATION( 
activemq::transport::correlator::ResponseCorrelatorTest );
 //