summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-01-18 22:46:04 +0000
committerAlan Conway <aconway@apache.org>2012-01-18 22:46:04 +0000
commit43253d1d65d21c74f54268d827dce4342f21daa2 (patch)
tree09a96dd741dcf4d0193391c3203cdf6660fac3be
parent4debb1e320764965d7eaf29a1fb47363f8b9313f (diff)
downloadqpid-python-43253d1d65d21c74f54268d827dce4342f21daa2.tar.gz
QPID-3603: Replace public broker::Consumer::position variable with get/set function pair.
Fix to r1233080 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1233102 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/broker/Queue.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp
index 6334524612..329fd1cb8c 100644
--- a/qpid/cpp/src/qpid/broker/Queue.cpp
+++ b/qpid/cpp/src/qpid/broker/Queue.cpp
@@ -309,7 +309,7 @@ Queue::ConsumeCode Queue::consumeNextMessage(QueuedMessage& m, Consumer::shared_
if (msg.payload->hasExpired()) {
QPID_LOG(debug, "Message expired from queue '" << name << "'");
- c->getPosition() = msg.position;
+ c->setPosition(msg.position);
acquire( msg.position, msg, locker);
dequeue( 0, msg );
continue;
@@ -324,7 +324,7 @@ Queue::ConsumeCode Queue::consumeNextMessage(QueuedMessage& m, Consumer::shared_
ok = acquire( msg.position, msg, locker);
(void) ok; assert(ok);
m = msg;
- c->getPosition() = m.position;
+ c->setPosition(m.position);
return CONSUMED;
} else {
//message(s) are available but consumer hasn't got enough credit
@@ -334,7 +334,7 @@ Queue::ConsumeCode Queue::consumeNextMessage(QueuedMessage& m, Consumer::shared_
} else {
//consumer will never want this message
QPID_LOG(debug, "Consumer doesn't want message from '" << name << "'");
- c->getPosition() = msg.position;
+ c->setPosition(msg.position);
return CANT_CONSUME;
}
}