summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/FailoverConnection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/client/FailoverConnection.cpp')
-rw-r--r--cpp/src/qpid/client/FailoverConnection.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/FailoverConnection.cpp b/cpp/src/qpid/client/FailoverConnection.cpp
index 3e982747ff..e98de868de 100644
--- a/cpp/src/qpid/client/FailoverConnection.cpp
+++ b/cpp/src/qpid/client/FailoverConnection.cpp
@@ -158,6 +158,10 @@ FailoverConnection::failover ( )
fs->prepareForFailover ( newConnection );
}
+ connection = newConnection;
+ connection.registerFailureCallback
+ ( boost::bind(&FailoverConnection::failover, this));
+
/*
* Tell all sessions to actually failover to the new connection.
*/
@@ -169,10 +173,6 @@ FailoverConnection::failover ( )
FailoverSession * fs = * sessions_iterator;
fs->failover ( );
}
-
- connection = newConnection;
- connection.registerFailureCallback
- ( boost::bind(&FailoverConnection::failover, this));
}