summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-12-07 14:12:59 +0000
committerGordon Sim <gsim@apache.org>2007-12-07 14:12:59 +0000
commit1932cc7d04e1ce58418dc2a1655c0118921727ea (patch)
tree811b18631bda717209d92cd1243ea8b121dab300
parent903470bd34742aad4ad2d3462fd005807f2b42ec (diff)
downloadqpid-python-1932cc7d04e1ce58418dc2a1655c0118921727ea.tar.gz
Further use of get_pointer function to mask differences between boost versions.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@602103 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--cpp/src/qpid/broker/SemanticState.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index cec0a21f67..9233685800 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -101,7 +101,7 @@ void SemanticState::consume(DeliveryToken::shared_ptr token, string& tagInOut,
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 @@ void SemanticState::acknowledged(const DeliveryRecord& delivery)
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 @@ SemanticState::ConsumerImpl& SemanticState::find(const std::string& destination)
if (i == consumers.end()) {
throw NotFoundException(QPID_MSG("Unknown destination " << destination));
} else {
- return *i;
+ return *get_pointer(i);
}
}