Author: aconway
Date: Wed Jan 18 22:46:04 2012
New Revision: 1233102
URL: http://svn.apache.org/viewvc?rev=1233102&view=rev
Log:
QPID-3603: Replace public broker::Consumer::position variable with get/set
function pair.
Fix to r1233080
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=1233102&r1=1233101&r2=1233102&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Wed Jan 18 22:46:04 2012
@@ -309,7 +309,7 @@ Queue::ConsumeCode Queue::consumeNextMes
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::consumeNextMes
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::consumeNextMes
} 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;
}
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
