diff options
| author | Gordon Sim <gsim@apache.org> | 2015-07-27 19:59:48 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2015-07-27 19:59:48 +0000 |
| commit | e25498363eb4b5baf48d23e2fc819c85d04cc552 (patch) | |
| tree | 44c74a600956120ea91097158a58e2438b912cec | |
| parent | e8e2210145df9122b0239782ec75863b55efb822 (diff) | |
| download | qpid-python-e25498363eb4b5baf48d23e2fc819c85d04cc552.tar.gz | |
QPID-6660: don't try to process incoming delivery events for link that has been closed
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1692938 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/cpp/src/qpid/broker/amqp/Connection.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/amqp/Connection.cpp b/qpid/cpp/src/qpid/broker/amqp/Connection.cpp index 322192f551..be2e335c4d 100644 --- a/qpid/cpp/src/qpid/broker/amqp/Connection.cpp +++ b/qpid/cpp/src/qpid/broker/amqp/Connection.cpp @@ -633,6 +633,8 @@ void Connection::doLinkRemoteDetach(pn_link_t *link, bool closed) void Connection::doDeliveryUpdated(pn_delivery_t *delivery) { pn_link_t* link = pn_delivery_link(delivery); + if (pn_link_state(link) & PN_LOCAL_CLOSED) return; + try { if (pn_link_is_receiver(link)) { Sessions::iterator i = sessions.find(pn_link_session(link)); |