diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2008-12-16 21:41:01 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2008-12-16 21:41:01 +0000 |
| commit | c5d4420b0bf574200158ba943d74f9bfd13ad56e (patch) | |
| tree | 7420561262882208ce9936f4a6e6e2dad3255709 /cpp/src/qpid/client | |
| parent | 66d295bf47c6c91ecd2b1e7054d44e877429f1ed (diff) | |
| download | qpid-python-c5d4420b0bf574200158ba943d74f9bfd13ad56e.tar.gz | |
LVQ queue option for no acquire
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727166 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client')
| -rw-r--r-- | cpp/src/qpid/client/QueueOptions.cpp | 5 | ||||
| -rw-r--r-- | cpp/src/qpid/client/QueueOptions.h | 3 |
2 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/qpid/client/QueueOptions.cpp b/cpp/src/qpid/client/QueueOptions.cpp index 66cf8544f0..b360c1ab93 100644 --- a/cpp/src/qpid/client/QueueOptions.cpp +++ b/cpp/src/qpid/client/QueueOptions.cpp @@ -38,6 +38,7 @@ const std::string QueueOptions::strRING_STRICT("ring_strict"); const std::string QueueOptions::strLastValueQueue("qpid.last_value_queue"); const std::string QueueOptions::strPersistLastNode("qpid.persist_last_node"); const std::string QueueOptions::strLVQMatchProperty("qpid.LVQ_key"); +const std::string QueueOptions::strLastValueQueueNoAcquire("qpid.last_value_queue_no_acquire"); QueueOptions::~QueueOptions() @@ -79,7 +80,9 @@ void QueueOptions::setOrdering(QueueOrderingPolicy op) { if (op == LVQ){ setInt(strLastValueQueue, 1); - }else{ + }else if (op == LVQ_NO_ACQUIRE){ + setInt(strLastValueQueueNoAcquire, 1); + }else { clearOrdering(); } } diff --git a/cpp/src/qpid/client/QueueOptions.h b/cpp/src/qpid/client/QueueOptions.h index e9deb7ead8..c6cb071714 100644 --- a/cpp/src/qpid/client/QueueOptions.h +++ b/cpp/src/qpid/client/QueueOptions.h @@ -27,7 +27,7 @@ namespace qpid { namespace client { enum QueueSizePolicy {NONE, REJECT, FLOW_TO_DISK, RING, RING_STRICT}; -enum QueueOrderingPolicy {FIFO, LVQ}; +enum QueueOrderingPolicy {FIFO, LVQ, LVQ_NO_ACQUIRE}; /** * A help class to set options on the Queue. Create a configured args while @@ -94,6 +94,7 @@ class QueueOptions: public framing::FieldTable static const std::string strLastValueQueue; static const std::string strPersistLastNode; static const std::string strLVQMatchProperty; + static const std::string strLastValueQueueNoAcquire; }; } |
