1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/FailoverConnection.cpp b/cpp/src/qpid/client/FailoverConnection.cpp
index 33b06a6a1a..8b37ba5cfa 100644
--- a/cpp/src/qpid/client/FailoverConnection.cpp
+++ b/cpp/src/qpid/client/FailoverConnection.cpp
@@ -129,7 +129,7 @@ FailoverConnection::failover ( )
         ++ sessions_iterator )
   {
     FailoverSession * fs = * sessions_iterator;
-    fs->failover_in_progress = true;
+    fs->failoverStarting();
   }
 
     std::vector<Url> knownBrokers = connection.getKnownBrokers();
@@ -187,7 +187,7 @@ FailoverConnection::failover ( )
     )
     {
         FailoverSession * fs = * sessions_iterator;
-        fs->failover_in_progress = false;
+        fs->failoverComplete();
     }
 }