diff options
author | Ted Ross <tross@apache.org> | 2010-02-26 20:07:36 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2010-02-26 20:07:36 +0000 |
commit | b462279113238af55b05b381e95e9f5371e28304 (patch) | |
tree | cee0f7e95049ad841d48b5eae6a33206f5338032 /cpp/src/tests/MessagingSessionTests.cpp | |
parent | 7480298d6d19ad3cd5db18e44e909d074bc2037a (diff) | |
download | qpid-python-b462279113238af55b05b381e95e9f5371e28304.tar.gz |
QPID-2423 - Add Constructors to set initial value of content for MapContent and ListContent
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@916803 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/MessagingSessionTests.cpp')
-rw-r--r-- | cpp/src/tests/MessagingSessionTests.cpp | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp index 9c6f066d64..98b92e809c 100644 --- a/cpp/src/tests/MessagingSessionTests.cpp +++ b/cpp/src/tests/MessagingSessionTests.cpp @@ -346,6 +346,25 @@ QPID_AUTO_TEST_CASE(testMapMessage) fix.session.acknowledge(); } +QPID_AUTO_TEST_CASE(testMapMessageWithInitial) +{ + QueueFixture fix; + Sender sender = fix.session.createSender(fix.queue); + Message out; + Variant::Map imap; + imap["abc"] = "def"; + imap["pi"] = 3.14f; + MapContent content(out, imap); + content.encode(); + sender.send(out); + Receiver receiver = fix.session.createReceiver(fix.queue); + Message in = receiver.fetch(5 * qpid::sys::TIME_SEC); + MapView view(in); + BOOST_CHECK_EQUAL(view["abc"].asString(), "def"); + BOOST_CHECK_EQUAL(view["pi"].asFloat(), 3.14f); + fix.session.acknowledge(); +} + QPID_AUTO_TEST_CASE(testListMessage) { QueueFixture fix; @@ -379,6 +398,40 @@ QPID_AUTO_TEST_CASE(testListMessage) fix.session.acknowledge(); } +QPID_AUTO_TEST_CASE(testListMessageWithInitial) +{ + QueueFixture fix; + Sender sender = fix.session.createSender(fix.queue); + Message out; + Variant::List ilist; + ilist.push_back(Variant("abc")); + ilist.push_back(Variant(1234)); + ilist.push_back(Variant("def")); + ilist.push_back(Variant(56.789)); + ListContent content(out, ilist); + content.encode(); + sender.send(out); + Receiver receiver = fix.session.createReceiver(fix.queue); + Message in = receiver.fetch(5 * qpid::sys::TIME_SEC); + ListView view(in); + BOOST_CHECK_EQUAL(view.size(), content.size()); + BOOST_CHECK_EQUAL(view.front().asString(), "abc"); + BOOST_CHECK_EQUAL(view.back().asDouble(), 56.789); + + ListView::const_iterator i = view.begin(); + BOOST_CHECK(i != view.end()); + BOOST_CHECK_EQUAL(i->asString(), "abc"); + BOOST_CHECK(++i != view.end()); + BOOST_CHECK_EQUAL(i->asInt64(), 1234); + BOOST_CHECK(++i != view.end()); + BOOST_CHECK_EQUAL(i->asString(), "def"); + BOOST_CHECK(++i != view.end()); + BOOST_CHECK_EQUAL(i->asDouble(), 56.789); + BOOST_CHECK(++i == view.end()); + + fix.session.acknowledge(); +} + QPID_AUTO_TEST_CASE(testReject) { QueueFixture fix; |