activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r750164 - /activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp
Date Wed, 04 Mar 2009 21:38:05 GMT
Author: tabish
Date: Wed Mar  4 21:38:04 2009
New Revision: 750164

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

Fix a couple more errors.

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp

Modified: activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp?rev=750164&r1=750163&r2=750164&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp
Wed Mar  4 21:38:04 2009
@@ -59,6 +59,10 @@
     this->trackMessages = false;
     this->maxCacheSize = 128 * 1024;
 
+    this->started = false;
+    this->closed = false;
+    this->connected = false;
+
     this->stateTracker.setTrackTransactions( true );
     this->myTransportListener.reset( new FailoverTransportListener( this ) );
     this->reconnectTask.reset( new ReconnectTask( this ) );
@@ -351,7 +355,7 @@
             stateTracker.setMaxCacheSize( this->getMaxCacheSize() );
             stateTracker.setTrackMessages( this->isTrackMessages() );
 
-            if( connectedTransport.get() != NULL ) {
+            if( connectedTransport != NULL ) {
                 stateTracker.restore( connectedTransport );
             } else {
                 reconnect();



Mime
View raw message