diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Connection.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index 7406d64bda..2a98800484 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -463,15 +463,15 @@ void Connection::membership(const FieldTable& joiners, const FieldTable& members const framing::SequenceNumber& frameSeq) { QPID_LOG(debug, cluster << " incoming update complete on connection " << *this); - cluster.updateInDone(ClusterMap(joiners, members, frameSeq)); updateIn.consumerNumbering.clear(); closeUpdated(); + cluster.updateInDone(ClusterMap(joiners, members, frameSeq)); } void Connection::retractOffer() { QPID_LOG(info, cluster << " incoming update retracted on connection " << *this); - cluster.updateInRetracted(); closeUpdated(); + cluster.updateInRetracted(); } void Connection::closeUpdated() { |