From 7a4f554f249787b7de06d1bf6e61d5c587a28f1a Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 10 Oct 2008 23:32:02 +0000 Subject: src/client/FailoverConnection.cpp: re-register callback after failures git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703604 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/client/FailoverConnection.cpp | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) (limited to 'cpp/src/qpid') diff --git a/cpp/src/qpid/client/FailoverConnection.cpp b/cpp/src/qpid/client/FailoverConnection.cpp index c5d775bf82..3e982747ff 100644 --- a/cpp/src/qpid/client/FailoverConnection.cpp +++ b/cpp/src/qpid/client/FailoverConnection.cpp @@ -126,7 +126,7 @@ FailoverConnection::failover ( ) { std::vector 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::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)); } -- cgit v1.2.1