svn commit: r750164 - /activemq/activemq-cpp/trunk/src/main/activemq/transport/failover/FailoverTransport.cpp

[tabish]

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();