summaryrefslogtreecommitdiff
path: root/qpid/cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2009-04-08 10:06:56 +0000
committerGordon Sim <gsim@apache.org>2009-04-08 10:06:56 +0000
commitedd926243bf0946a7b2c4f82fa174a4f0677b98f (patch)
tree46769bd034f00d70f2d16113ae49a1c29910e590 /qpid/cpp
parente414722c8ea7a3f71f565130e86558a85233d79c (diff)
downloadqpid-python-edd926243bf0946a7b2c4f82fa174a4f0677b98f.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@763163 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
-rw-r--r--qpid/cpp/src/qpid/client/ConnectionImpl.cpp8
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