diff options
| author | Gordon Sim <gsim@apache.org> | 2009-04-06 12:38:55 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2009-04-06 12:38:55 +0000 |
| commit | d078fcd8aa02296787a95e9344d308468cc49341 (patch) | |
| tree | ab003aaf67be26bb199e891760e103b497dee176 /qpid/cpp/src | |
| parent | 29f2af3ba16e9e89600cbea3535429ed932c5c9e (diff) | |
| download | qpid-python-d078fcd8aa02296787a95e9344d308468cc49341.tar.gz | |
QPID-1785: Prevent session.detach frame following an execution.exception causing connection to be closed.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.5-release@762312 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/client/ConnectionImpl.cpp | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/client/ConnectionImpl.cpp b/qpid/cpp/src/qpid/client/ConnectionImpl.cpp index 745bdb63b5..b1e83025ab 100644 --- a/qpid/cpp/src/qpid/client/ConnectionImpl.cpp +++ b/qpid/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 |