diff options
| -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)); |