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/tests/QueueTest.cpp | |
| 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/tests/QueueTest.cpp')
| -rw-r--r-- | cpp/src/tests/QueueTest.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
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<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); } |