src/client/FailoverConnection.cpp: re-register callback after failures

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@703604 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 7 deletions

diff --git a/qpid/cpp/src/qpid/client/FailoverConnection.cpp b/qpid/cpp/src/qpid/client/FailoverConnection.cpp
index c5d775bf82..3e982747ff 100644
--- a/qpid/cpp/src/qpid/client/FailoverConnection.cpp
+++ b/qpid/cpp/src/qpid/client/FailoverConnection.cpp
@@ -126,7 +126,7 @@ FailoverConnection::failover ( )
 {
     std::vector<Url> knownBrokers = connection.getKnownBrokers();
     if (knownBrokers.empty())
-         throw Exception(QPID_MSG("FailoverConnection::failover " << name << " no known brokers."));
+        throw Exception(QPID_MSG("FailoverConnection::failover " << name << " no known brokers."));
 
     Connection newConnection;
     for (std::vector<Url>::iterator i = knownBrokers.begin(); i != knownBrokers.end(); ++i) {
@@ -171,12 +171,8 @@ FailoverConnection::failover ( )
     }
 
     connection = newConnection;
-
-    // FIXME aconway 2008-10-09: use sys/Time.h functions.
-    if ( failoverCompleteTime )
-    {
-        gettimeofday ( failoverCompleteTime, 0 );
-    }
+    connection.registerFailureCallback
+        ( boost::bind(&FailoverConnection::failover, this));
 }