From 5748390087f011559549ec33f538e5a3babd43fe Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 7 Sep 2009 09:15:40 +0000 Subject: QPID-664: Added automatic reconnection logic. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@812049 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/MessagingSessionTests.cpp | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) (limited to 'cpp/src/tests/MessagingSessionTests.cpp') diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp index be0b6f42d0..2cbcc8d500 100644 --- a/cpp/src/tests/MessagingSessionTests.cpp +++ b/cpp/src/tests/MessagingSessionTests.cpp @@ -183,6 +183,26 @@ QPID_AUTO_TEST_CASE(testSimpleSendReceive) BOOST_CHECK_EQUAL(in.getBytes(), out.getBytes()); } +QPID_AUTO_TEST_CASE(testSendReceiveHeaders) +{ + QueueFixture fix; + Sender sender = fix.session.createSender(fix.queue); + Message out("test-message"); + for (uint i = 0; i < 10; ++i) { + out.getHeaders()["a"] = i; + sender.send(out); + } + Receiver receiver = fix.session.createReceiver(fix.queue); + Message in; + for (uint i = 0; i < 10; ++i) { + //Message in = receiver.fetch(5 * qpid::sys::TIME_SEC); + BOOST_CHECK(receiver.fetch(in, 5 * qpid::sys::TIME_SEC)); + BOOST_CHECK_EQUAL(in.getBytes(), out.getBytes()); + BOOST_CHECK_EQUAL(in.getHeaders()["a"].asUint32(), i); + fix.session.acknowledge(); + } +} + QPID_AUTO_TEST_CASE(testSenderError) { MessagingFixture fix; -- cgit v1.2.1