You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/12/07 15:13:00 UTC

svn commit: r602103 - /incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp

Author: gsim
Date: Fri Dec  7 06:12:59 2007
New Revision: 602103

URL: http://svn.apache.org/viewvc?rev=602103&view=rev
Log:
Further use of get_pointer function to mask differences between boost versions.


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=602103&r1=602102&r2=602103&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp Fri Dec  7 06:12:59 2007
@@ -101,7 +101,7 @@
 void SemanticState::cancel(const string& tag){
     ConsumerImplMap::iterator i = consumers.find(tag);
     if (i != consumers.end()) {
-        cancel(*i);
+        cancel(*get_pointer(i));
         consumers.erase(i); 
         //should cancel all unacked messages for this consumer so that
         //they are not redelivered on recovery
@@ -436,7 +436,7 @@
     delivery.subtractFrom(outstanding);
     ConsumerImplMap::iterator i = consumers.find(delivery.getTag());
     if (i != consumers.end()) {
-        i->acknowledged(delivery);
+        get_pointer(i)->acknowledged(delivery);
     }
 }
 
@@ -502,7 +502,7 @@
     if (i == consumers.end()) {
         throw NotFoundException(QPID_MSG("Unknown destination " << destination));
     } else {
-        return *i;
+        return *get_pointer(i);
     }
 }