summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/FailoverConnection.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-14 18:21:50 +0000
committerAlan Conway <aconway@apache.org>2008-10-14 18:21:50 +0000
commitb17ea7f64cf3eb42c4614aa57508a7aaca132807 (patch)
tree3f79c52e3b96a19cb0ce6b591b5ea64284c41cad /cpp/src/qpid/client/FailoverConnection.cpp
parent8ec6597d5372ccebb689483b8074085f278022e1 (diff)
downloadqpid-python-b17ea7f64cf3eb42c4614aa57508a7aaca132807.tar.gz
Bug fixes for client-side failover.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704596 13f79535-47bb-0310-9956-ffa450edef68
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));
}