summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SemanticState.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-04-21 18:59:31 +0000
committerAlan Conway <aconway@apache.org>2008-04-21 18:59:31 +0000
commit3097509ae43d93c1832638f80ba2ad5810fbef44 (patch)
tree96a6a73a5ab8a54aa49983f0f20881964d7418b8 /cpp/src/qpid/broker/SemanticState.cpp
parent69a3af237753a91e9cf8dbb98e890131d53e3ee3 (diff)
downloadqpid-python-3097509ae43d93c1832638f80ba2ad5810fbef44.tar.gz
Better workaround for boost::ptr_map incompatibility between boost 1.33 and 1.34, based on public properties of ptr::map types rather than version numbers.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@650221 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SemanticState.cpp')
-rw-r--r--cpp/src/qpid/broker/SemanticState.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/SemanticState.cpp b/cpp/src/qpid/broker/SemanticState.cpp
index c2f6e3c307..2c2d099fb1 100644
--- a/cpp/src/qpid/broker/SemanticState.cpp
+++ b/cpp/src/qpid/broker/SemanticState.cpp
@@ -58,7 +58,7 @@ using boost::intrusive_ptr;
using namespace qpid::broker;
using namespace qpid::framing;
using namespace qpid::sys;
-using namespace qpid::ptr_map;
+using qpid::ptr_map_ptr;
SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss)
: session(ss),
@@ -77,7 +77,7 @@ SemanticState::SemanticState(DeliveryAdapter& da, SessionContext& ss)
SemanticState::~SemanticState() {
//cancel all consumers
for (ConsumerImplMap::iterator i = consumers.begin(); i != consumers.end(); i++) {
- cancel(*get_pointer(i));
+ cancel(*ptr_map_ptr(i));
}
if (dtxBuffer.get()) {
@@ -105,7 +105,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(*get_pointer(i));
+ cancel(*ptr_map_ptr(i));
consumers.erase(i);
//should cancel all unacked messages for this consumer so that
//they are not redelivered on recovery
@@ -429,7 +429,7 @@ void SemanticState::ack(DeliveryId first, DeliveryId last, bool cumulative)
void SemanticState::requestDispatch()
{
for (ConsumerImplMap::iterator i = consumers.begin(); i != consumers.end(); i++) {
- requestDispatch(*get_pointer(i));
+ requestDispatch(*ptr_map_ptr(i));
}
}
@@ -445,7 +445,7 @@ void SemanticState::complete(DeliveryRecord& delivery)
delivery.subtractFrom(outstanding);
ConsumerImplMap::iterator i = consumers.find(delivery.getTag());
if (i != consumers.end()) {
- get_pointer(i)->complete(delivery);
+ ptr_map_ptr(i)->complete(delivery);
}
}
@@ -514,7 +514,7 @@ SemanticState::ConsumerImpl& SemanticState::find(const std::string& destination)
if (i == consumers.end()) {
throw NotFoundException(QPID_MSG("Unknown destination " << destination));
} else {
- return *get_pointer(i);
+ return *ptr_map_ptr(i);
}
}