QPID-1306

- added lvq support
- added lvq tests
- added safety test for lvq
- updated QueueOptions for lvq
- some refactor to queue, to have signel pop loction



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@702958 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 4 deletions

diff --git a/cpp/src/qpid/client/QueueOptions.cpp b/cpp/src/qpid/client/QueueOptions.cpp
index d0fd6f1e5c..5d1cb74efd 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::strOptimisticConsume("qpid.optimistic_consume");
 const std::string QueueOptions::strPersistLastNode("qpid.persist_last_node");
+const std::string QueueOptions::strLVQMatchProperty("qpid.LVQ_key");
 
 
 QueueOptions::~QueueOptions()
@@ -83,15 +84,17 @@ void QueueOptions::setPersistLastNode()
 void QueueOptions::setOrdering(QueueOrderingPolicy op)
 {
 	if (op == LVQ){
-	     // TODO, add and test options with LVQ patch.
-		 // also set the key match for LVQ
-	     //setString(LastValueQueue, 1); 
-	
+	    setInt(strLastValueQueue, 1); 
 	}else{
 	    clearOrdering();
 	}
 }
 
+void QueueOptions::getLVQKey(std::string& key)
+{
+    key.assign(strLVQMatchProperty);
+}
+
 void QueueOptions::clearSizePolicy()
 {
     erase(strMaxCountKey);