diff options
| author | Alan Conway <aconway@apache.org> | 2008-04-21 18:59:31 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2008-04-21 18:59:31 +0000 |
| commit | 3097509ae43d93c1832638f80ba2ad5810fbef44 (patch) | |
| tree | 96a6a73a5ab8a54aa49983f0f20881964d7418b8 /cpp/src/qpid/broker/SemanticState.cpp | |
| parent | 69a3af237753a91e9cf8dbb98e890131d53e3ee3 (diff) | |
| download | qpid-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.cpp | 12 |
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); } } |
