summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2008-12-17 21:26:55 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2008-12-17 21:26:55 +0000
commitc146f7f3af6ecac234498102e97175927347bd71 (patch)
treef202d3ceee5d631c32db27cdda9a38ca2c149e65 /cpp/src/qpid/broker
parent27c83f981b62cbff3aa4d5910acca4e0c68ec165 (diff)
downloadqpid-python-c146f7f3af6ecac234498102e97175927347bd71.tar.gz
options name re-name to be more explicit & better test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727517 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker')
-rw-r--r--cpp/src/qpid/broker/Queue.cpp16
-rw-r--r--cpp/src/qpid/broker/Queue.h2
2 files changed, 9 insertions, 9 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index a1273c572b..418722f40b 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -61,7 +61,7 @@ const std::string qpidNoLocal("no-local");
const std::string qpidTraceIdentity("qpid.trace.id");
const std::string qpidTraceExclude("qpid.trace.exclude");
const std::string qpidLastValueQueue("qpid.last_value_queue");
-const std::string qpidLastValueQueueNoAcquire("qpid.last_value_queue_no_acquire");
+const std::string qpidLastValueQueueNoBrowse("qpid.last_value_queue_no_browse");
const std::string qpidPersistLastNode("qpid.persist_last_node");
const std::string qpidVQMatchProperty("qpid.LVQ_key");
}
@@ -80,7 +80,7 @@ Queue::Queue(const string& _name, bool _autodelete,
exclusive(0),
noLocal(false),
lastValueQueue(false),
- lastValueQueueNoAcquire(false),
+ lastValueQueueNoBrowse(false),
persistLastNode(false),
inLastNodeFailure(false),
persistenceId(0),
@@ -215,7 +215,7 @@ bool Queue::acquire(const QueuedMessage& msg) {
|| (lastValueQueue && (i->position == msg.position) &&
msg.payload.get() == checkLvqReplace(*i).payload.get()) ) {
- if (!lastValueQueueNoAcquire) clearLVQIndex(msg);
+ clearLVQIndex(msg);
messages.erase(i);
QPID_LOG(debug, "Match found, acquire succeeded: " << i->position << " == " << msg.position);
return true;
@@ -307,7 +307,7 @@ bool Queue::browseNextMessage(QueuedMessage& m, Consumer::shared_ptr c)
//consumer wants the message
c->position = msg.position;
m = msg;
- if (!lastValueQueueNoAcquire) clearLVQIndex(msg);
+ if (!lastValueQueueNoBrowse) clearLVQIndex(msg);
return true;
} else {
//browser hasn't got enough credit for the message
@@ -675,10 +675,10 @@ void Queue::configure(const FieldTable& _settings)
lastValueQueue= _settings.get(qpidLastValueQueue);
if (lastValueQueue) QPID_LOG(debug, "Configured queue as Last Value Queue");
- lastValueQueueNoAcquire = _settings.get(qpidLastValueQueueNoAcquire);
- if (lastValueQueueNoAcquire){
- QPID_LOG(debug, "Configured queue as Last Value Queue No Acquire");
- lastValueQueue = lastValueQueueNoAcquire;
+ lastValueQueueNoBrowse = _settings.get(qpidLastValueQueueNoBrowse);
+ if (lastValueQueueNoBrowse){
+ QPID_LOG(debug, "Configured queue as Last Value Queue No Browse");
+ lastValueQueue = lastValueQueueNoBrowse;
}
persistLastNode= _settings.get(qpidPersistLastNode);
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h
index 89cd3afc35..e0bcc25fa3 100644
--- a/cpp/src/qpid/broker/Queue.h
+++ b/cpp/src/qpid/broker/Queue.h
@@ -76,7 +76,7 @@ namespace qpid {
OwnershipToken* exclusive;
bool noLocal;
bool lastValueQueue;
- bool lastValueQueueNoAcquire;
+ bool lastValueQueueNoBrowse;
bool persistLastNode;
bool inLastNodeFailure;
std::string traceId;