summaryrefslogtreecommitdiff
path: root/cpp/src/tests/QueueTest.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2009-07-08 16:20:47 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2009-07-08 16:20:47 +0000
commit7d0d5cffd8ee55f21e6a10e70bf1febd32fc97df (patch)
treecc55757e321eb29c9972aef3927871179465145c /cpp/src/tests/QueueTest.cpp
parent54fd2688c4139593e536c3d36dcc9ad68680e101 (diff)
downloadqpid-python-7d0d5cffd8ee55f21e6a10e70bf1febd32fc97df.tar.gz
test for last commit
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@792210 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/QueueTest.cpp')
-rw-r--r--cpp/src/tests/QueueTest.cpp19
1 files changed, 18 insertions, 1 deletions
diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp
index d987e07a02..5aad3da7dd 100644
--- a/cpp/src/tests/QueueTest.cpp
+++ b/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()