diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster')
| -rw-r--r-- | qpid/cpp/src/qpid/cluster/UpdateClient.cpp | 7 | ||||
| -rw-r--r-- | qpid/cpp/src/qpid/cluster/UpdateClient.h | 2 |
2 files changed, 4 insertions, 5 deletions
diff --git a/qpid/cpp/src/qpid/cluster/UpdateClient.cpp b/qpid/cpp/src/qpid/cluster/UpdateClient.cpp index e5d20c85e6..4f6488a28a 100644 --- a/qpid/cpp/src/qpid/cluster/UpdateClient.cpp +++ b/qpid/cpp/src/qpid/cluster/UpdateClient.cpp @@ -497,7 +497,7 @@ void UpdateClient::updateConsumer( ci->isNotifyEnabled(), ci->position ); - consumerNumbering.add(ci); + consumerNumbering.add(ci.get()); QPID_LOG(debug, *this << " updated consumer " << ci->getName() << " on " << shadowSession.getId()); @@ -584,10 +584,9 @@ void UpdateClient::updateQueueListeners(const boost::shared_ptr<broker::Queue>& } void UpdateClient::updateQueueListener(std::string& q, - const boost::shared_ptr<broker::Consumer>& c) + const boost::shared_ptr<broker::Consumer>& c) { - const boost::shared_ptr<SemanticState::ConsumerImpl> ci = - boost::dynamic_pointer_cast<SemanticState::ConsumerImpl>(c); + SemanticState::ConsumerImpl* ci = dynamic_cast<SemanticState::ConsumerImpl*>(c.get()); size_t n = consumerNumbering[ci]; if (n >= consumerNumbering.size()) throw Exception(QPID_MSG("Unexpected listener on queue " << q)); diff --git a/qpid/cpp/src/qpid/cluster/UpdateClient.h b/qpid/cpp/src/qpid/cluster/UpdateClient.h index 156fa112df..7520bb82cb 100644 --- a/qpid/cpp/src/qpid/cluster/UpdateClient.h +++ b/qpid/cpp/src/qpid/cluster/UpdateClient.h @@ -106,7 +106,7 @@ class UpdateClient : public sys::Runnable { void updateBridge(const boost::shared_ptr<broker::Bridge>&); - Numbering<broker::SemanticState::ConsumerImpl::shared_ptr> consumerNumbering; + Numbering<broker::SemanticState::ConsumerImpl*> consumerNumbering; MemberId updaterId; MemberId updateeId; Url updateeUrl; |