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);
}
}