From 51e77c8bc7dc4d71422b421135ded1cb33bb5c55 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 12 Nov 2009 10:30:53 +0000 Subject: Merge branch 'next_receiver_changes' into trunk git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@835323 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/MessagingSessionTests.cpp | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) (limited to 'cpp/src/tests/MessagingSessionTests.cpp') diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp index ce29099ef9..dd7166df46 100644 --- a/cpp/src/tests/MessagingSessionTests.cpp +++ b/cpp/src/tests/MessagingSessionTests.cpp @@ -354,6 +354,28 @@ QPID_AUTO_TEST_CASE(testSessionDispatch) BOOST_CHECK_EQUAL(collector.messageData, boost::assign::list_of("Message_1")("Message_2")("Message_3")); } +QPID_AUTO_TEST_CASE(testNextReceiver) +{ + MultiQueueFixture fix; + + for (uint i = 0; i < fix.queues.size(); i++) { + Receiver r = fix.session.createReceiver(fix.queues[i]); + r.setCapacity(10u); + r.start();//TODO: add Session::start + } + + for (uint i = 0; i < fix.queues.size(); i++) { + Sender s = fix.session.createSender(fix.queues[i]); + Message msg((boost::format("Message_%1%") % (i+1)).str()); + s.send(msg); + } + + for (uint i = 0; i < fix.queues.size(); i++) { + Message msg; + BOOST_CHECK(fix.session.nextReceiver().fetch(msg, qpid::sys::TIME_SEC)); + BOOST_CHECK_EQUAL(msg.getContent(), (boost::format("Message_%1%") % (i+1)).str()); + } +} QPID_AUTO_TEST_CASE(testMapMessage) { -- cgit v1.2.1