diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2009-07-08 16:20:47 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2009-07-08 16:20:47 +0000 |
| commit | 119726c14a35a64bd71fe78dfe3a9887c7f6fb80 (patch) | |
| tree | 208c66076abd196f989e6ad8928c69211808ff1c /qpid/cpp/src | |
| parent | 0b3d49880e0f6137dfe3d62cd15613052b3fce04 (diff) | |
| download | qpid-python-119726c14a35a64bd71fe78dfe3a9887c7f6fb80.tar.gz | |
test for last commit
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@792210 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/tests/QueueTest.cpp | 19 |
1 files changed, 18 insertions, 1 deletions
diff --git a/qpid/cpp/src/tests/QueueTest.cpp b/qpid/cpp/src/tests/QueueTest.cpp index d987e07a02..5aad3da7dd 100644 --- a/qpid/cpp/src/tests/QueueTest.cpp +++ b/qpid/cpp/src/tests/QueueTest.cpp @@ -576,8 +576,25 @@ QPID_AUTO_TEST_CASE(testMultiQueueLastNode){ queue2->setLastNodeFailure(); BOOST_CHECK_EQUAL(testStore.enqCnt, 6u); -} + // check requeue 1 + intrusive_ptr<Message> msg4 = create_message("e", "C"); + intrusive_ptr<Message> msg5 = create_message("e", "D"); + framing::SequenceNumber sequence(1); + QueuedMessage qmsg1(queue1.get(), msg4, sequence); + QueuedMessage qmsg2(queue2.get(), msg5, ++sequence); + + queue1->requeue(qmsg1); + BOOST_CHECK_EQUAL(testStore.enqCnt, 7u); + + // check requeue 2 + queue2->clearLastNodeFailure(); + queue2->requeue(qmsg2); + BOOST_CHECK_EQUAL(testStore.enqCnt, 7u); + queue2->setLastNodeFailure(); + BOOST_CHECK_EQUAL(testStore.enqCnt, 8u); + +} QPID_AUTO_TEST_SUITE_END() |