diff options
| author | Gordon Sim <gsim@apache.org> | 2009-04-08 10:06:56 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2009-04-08 10:06:56 +0000 |
| commit | 7bff2d54e00407583e65b8eab8a2a078e731bbd8 (patch) | |
| tree | 1775e0e48dfcdf1da0477a65bb3ad1a80192f746 /cpp/src | |
| parent | d3ee6b8bd4fd318b1623fa12b6067ddb1993e134 (diff) | |
| download | qpid-python-7bff2d54e00407583e65b8eab8a2a078e731bbd8.tar.gz | |
QPID-1785: Prevent session.detach following execution.exception from destroying the connection.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@763163 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/client/ConnectionImpl.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/cpp/src/qpid/client/ConnectionImpl.cpp b/cpp/src/qpid/client/ConnectionImpl.cpp index 745bdb63b5..b1e83025ab 100644 --- a/cpp/src/qpid/client/ConnectionImpl.cpp +++ b/cpp/src/qpid/client/ConnectionImpl.cpp @@ -111,9 +111,11 @@ void ConnectionImpl::incoming(framing::AMQFrame& frame) Mutex::ScopedLock l(lock); s = sessions[frame.getChannel()].lock(); } - if (!s) - throw NotAttachedException(QPID_MSG("Invalid channel: " << frame.getChannel())); - s->in(frame); + if (!s) { + QPID_LOG(info, "Dropping frame received on invalid channel: " << frame); + } else { + s->in(frame); + } } bool ConnectionImpl::isOpen() const |