You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by nm...@apache.org on 2007/01/07 15:38:04 UTC
svn commit: r493730 -
/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp
Author: nmittler
Date: Sun Jan 7 06:38:03 2007
New Revision: 493730
URL: http://svn.apache.org/viewvc?view=rev&rev=493730
Log:
AMQCPP-28 - Applying patch for memory leak in ExpirationTest
Modified:
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp
Modified: incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp
URL: http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp?view=diff&rev=493730&r1=493729&r2=493730
==============================================================================
--- incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp (original)
+++ incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/test-integration/integration/expiration/ExpirationTest.cpp Sun Jan 7 06:38:03 2007
@@ -85,6 +85,7 @@
class Producer : public Runnable {
private:
+ ActiveMQConnectionFactory* connectionFactory;
Connection* connection;
Session* session;
Topic* destination;
@@ -120,8 +121,7 @@
virtual void run() {
try {
// Create a ConnectionFactory
- ActiveMQConnectionFactory* connectionFactory = new
- ActiveMQConnectionFactory("tcp://localhost:61613");
+ connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61613");
// Create a Connection
connection = connectionFactory->createConnection();
@@ -188,6 +188,11 @@
if( connection != NULL ) delete connection;
}catch ( CMSException& e ) {}
connection = NULL;
+
+ try{
+ if( connectionFactory != NULL ) delete connectionFactory;
+ }catch ( CMSException& e ) {}
+ connectionFactory = NULL;
}
};