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 | cbe71e827eb0cc35867f43fc0c9c5177fd6e8082 (patch) | |
| tree | c26d4affd6f9ffe762a73459f4924e29db3581b1 /qpid/cpp/src/tests | |
| parent | cab5db31674b25b3c70b2ac5ed4ea97ab413f932 (diff) | |
| download | qpid-python-cbe71e827eb0cc35867f43fc0c9c5177fd6e8082.tar.gz | |
LVQ queue option for no acquire
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@727166 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests')
| -rw-r--r-- | qpid/cpp/src/tests/QueueTest.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp index c60ee6dcb5..fcd46da318 100644 --- a/qpid/cpp/src/tests/QueueTest.cpp +++ b/qpid/cpp/src/tests/QueueTest.cpp @@ -370,6 +370,7 @@ QPID_AUTO_TEST_CASE(testLVQAcquire){ intrusive_ptr<Message> msg3 = create_message("e", "C"); intrusive_ptr<Message> msg4 = create_message("e", "D"); intrusive_ptr<Message> msg5 = create_message("e", "F"); + intrusive_ptr<Message> 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<MessageProperties>()->getApplicationHeaders().setString(key,"c"); msg4->getProperties<MessageProperties>()->getApplicationHeaders().setString(key,"a"); msg5->getProperties<MessageProperties>()->getApplicationHeaders().setString(key,"b"); + msg6->getProperties<MessageProperties>()->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); } |