diff options
| author | Gordon Sim <gsim@apache.org> | 2013-07-17 08:58:57 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-07-17 08:58:57 +0000 |
| commit | 850e80ea566fc4d9662ce236351a88f32440517a (patch) | |
| tree | 68a416c823b00026f7cc101c375b9908cadb0739 /qpid/cpp/src/tests/MessagingSessionTests.cpp | |
| parent | 206e8c68e5a81816e265cf0f2465d8ff394c6675 (diff) | |
| download | qpid-python-850e80ea566fc4d9662ce236351a88f32440517a.tar.gz | |
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
Diffstat (limited to 'qpid/cpp/src/tests/MessagingSessionTests.cpp')
| -rw-r--r-- | qpid/cpp/src/tests/MessagingSessionTests.cpp | 19 |
1 files changed, 18 insertions, 1 deletions
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 |