qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject svn commit: r589778 - /incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
Date Mon, 29 Oct 2007 18:09:07 GMT
Author: gsim
Date: Mon Oct 29 11:09:05 2007
New Revision: 589778

URL: http://svn.apache.org/viewvc?rev=589778&view=rev
Log:
Check that session is attached before accepting delivery from queue (note further synching
is required between the actually delivery of frames and the change from attached to detached).


Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp?rev=589778&r1=589777&r2=589778&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp Mon Oct 29 11:09:05 2007
@@ -248,6 +248,10 @@
 
 bool SemanticState::ConsumerImpl::deliver(QueuedMessage& msg)
 {
+    if (!parent->getSession().isAttached()) {
+        return false;
+    }
+
     if (nolocal &&
         &parent->getSession().getConnection() == msg.payload->getPublisher()) {
         return false;



Mime
View raw message