From c146f7f3af6ecac234498102e97175927347bd71 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Wed, 17 Dec 2008 21:26:55 +0000 Subject: 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 --- cpp/src/tests/QueueTest.cpp | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) (limited to 'cpp/src/tests/QueueTest.cpp') diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp index fcd46da318..4d1de64180 100644 --- a/cpp/src/tests/QueueTest.cpp +++ b/cpp/src/tests/QueueTest.cpp @@ -43,7 +43,7 @@ public: intrusive_ptr last; bool received; - TestConsumer(): received(false) {}; + TestConsumer(bool acquire = true):Consumer(acquire), received(false) {}; virtual bool deliver(QueuedMessage& msg){ last = msg.payload; @@ -384,7 +384,7 @@ QPID_AUTO_TEST_CASE(testLVQAcquire){ msg3->getProperties()->getApplicationHeaders().setString(key,"c"); msg4->getProperties()->getApplicationHeaders().setString(key,"a"); msg5->getProperties()->getApplicationHeaders().setString(key,"b"); - msg6->getProperties()->getApplicationHeaders().setString(key,"a"); + msg6->getProperties()->getApplicationHeaders().setString(key,"c"); //enqueue 4 message queue->deliver(msg1); @@ -406,12 +406,17 @@ QPID_AUTO_TEST_CASE(testLVQAcquire){ queue->deliver(msg5); BOOST_CHECK_EQUAL(queue->getMessageCount(), 3u); - // set mode to no acquire and check - args.setOrdering(client::LVQ_NO_ACQUIRE); + // set mode to no browse and check + args.setOrdering(client::LVQ_NO_BROWSE); queue->configure(args); + TestConsumer::shared_ptr c1(new TestConsumer(false)); + + queue->dispatch(c1); + queue->dispatch(c1); + queue->dispatch(c1); + queue->deliver(msg6); BOOST_CHECK_EQUAL(queue->getMessageCount(), 3u); - } QPID_AUTO_TEST_CASE(testLVQMultiQueue){ -- cgit v1.2.1