From 850e80ea566fc4d9662ce236351a88f32440517a Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Wed, 17 Jul 2013 08:58:57 +0000 Subject: QPID-4993: reroute dropped messages in ring queue if alternate exchange is specified git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1504058 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/MessagingSessionTests.cpp | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) (limited to 'qpid/cpp/src/tests/MessagingSessionTests.cpp') diff --git a/qpid/cpp/src/tests/MessagingSessionTests.cpp b/qpid/cpp/src/tests/MessagingSessionTests.cpp index 9791cf9f38..2cf9648be4 100644 --- a/qpid/cpp/src/tests/MessagingSessionTests.cpp +++ b/qpid/cpp/src/tests/MessagingSessionTests.cpp @@ -1292,7 +1292,6 @@ QPID_AUTO_TEST_CASE(testSimpleRequestResponse) QPID_AUTO_TEST_CASE(testSelfDestructQueue) { MessagingFixture fix; - //create receiver on temp queue for responses (using shorthand for temp queue) Session other = fix.connection.createSession(); Receiver r1 = other.createReceiver("amq.fanout; {link:{reliability:at-least-once, x-declare:{arguments:{qpid.max_count:10,qpid.policy_type:self-destruct}}}}"); Receiver r2 = fix.session.createReceiver("amq.fanout"); @@ -1315,6 +1314,24 @@ QPID_AUTO_TEST_CASE(testSelfDestructQueue) } } +QPID_AUTO_TEST_CASE(testReroutingRingQueue) +{ + MessagingFixture fix; + Receiver r1 = fix.session.createReceiver("my-queue; {create:always, node:{x-declare:{alternate-exchange:amq.fanout, auto-delete:True, arguments:{qpid.max_count:10,qpid.policy_type:ring}}}}"); + Receiver r2 = fix.session.createReceiver("amq.fanout"); + + Sender s = fix.session.createSender("my-queue"); + for (uint i = 0; i < 20; ++i) { + s.send(Message((boost::format("MSG_%1%") % (i+1)).str())); + } + for (uint i = 10; i < 20; ++i) { + BOOST_CHECK_EQUAL(r1.fetch(Duration::SECOND).getContent(), (boost::format("MSG_%1%") % (i+1)).str()); + } + for (uint i = 0; i < 10; ++i) { + BOOST_CHECK_EQUAL(r2.fetch(Duration::SECOND).getContent(), (boost::format("MSG_%1%") % (i+1)).str()); + } +} + QPID_AUTO_TEST_SUITE_END() }} // namespace qpid::tests -- cgit v1.2.1