diff options
author | Gordon Sim <gsim@apache.org> | 2015-06-10 14:21:53 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2015-06-10 14:21:53 +0000 |
commit | 5f09dfc1ddb8c9b1f5943f62afec25f13c32815a (patch) | |
tree | 6eb9f6e80b22427dc0c431bbff9e54cf97f911c8 /qpid/cpp/src/qpid/broker/amqp/Session.cpp | |
parent | cbe3aeacc616bb8e3140bfa504eea3933525af63 (diff) | |
download | qpid-python-5f09dfc1ddb8c9b1f5943f62afec25f13c32815a.tar.gz |
QPID-6392: handle detach event
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1684680 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/amqp/Session.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Session.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Session.cpp b/qpid/cpp/src/qpid/broker/amqp/Session.cpp index 24da9e0fec..aa4ba03dfd 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Session.cpp +++ b/qpid/cpp/src/qpid/broker/amqp/Session.cpp @@ -591,12 +591,12 @@ void Session::attach(pn_link_t* link, const std::string& src, const std::string& } } -void Session::detach(pn_link_t* link) +void Session::detach(pn_link_t* link, bool closed) { if (pn_link_is_sender(link)) { OutgoingLinks::iterator i = outgoing.find(link); if (i != outgoing.end()) { - i->second->detached(true/*TODO: checked whether actually closed; see PROTON-773*/); + i->second->detached(closed); boost::shared_ptr<Queue> q = OutgoingFromQueue::getExclusiveSubscriptionQueue(i->second.get()); if (q && !q->isAutoDelete() && !q->isDeleted()) { connection.getBroker().deleteQueue(q->getName(), connection.getUserId(), connection.getMgmtId()); @@ -607,7 +607,7 @@ void Session::detach(pn_link_t* link) } else { IncomingLinks::iterator i = incoming.find(link); if (i != incoming.end()) { - i->second->detached(true/*TODO: checked whether actually closed; see PROTON-773*/); + i->second->detached(closed); incoming.erase(i); QPID_LOG(debug, "Incoming link detached"); } |