From c5d4420b0bf574200158ba943d74f9bfd13ad56e Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Tue, 16 Dec 2008 21:41:01 +0000 Subject: LVQ queue option for no acquire git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@727166 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/QueueTest.cpp | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'cpp/src/tests/QueueTest.cpp') diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp index c60ee6dcb5..fcd46da318 100644 --- a/cpp/src/tests/QueueTest.cpp +++ b/cpp/src/tests/QueueTest.cpp @@ -370,6 +370,7 @@ QPID_AUTO_TEST_CASE(testLVQAcquire){ intrusive_ptr msg3 = create_message("e", "C"); intrusive_ptr msg4 = create_message("e", "D"); intrusive_ptr msg5 = create_message("e", "F"); + intrusive_ptr msg6 = create_message("e", "G"); //set deliever match for LVQ a,b,c,a @@ -383,6 +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"); //enqueue 4 message queue->deliver(msg1); @@ -403,6 +405,12 @@ 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); + queue->configure(args); + queue->deliver(msg6); + BOOST_CHECK_EQUAL(queue->getMessageCount(), 3u); } -- cgit v1.2.1