diff options
| author | Gordon Sim <gsim@apache.org> | 2013-06-26 16:12:21 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-06-26 16:12:21 +0000 |
| commit | 408006d6d6543309b29d17eadb6df16fdd57fdf2 (patch) | |
| tree | b95b889e317e1eebab1e92e9dd8d10285bf527b1 /cpp/src/tests/MessagingSessionTests.cpp | |
| parent | 22115cc570ebdc27671adbdeb63db4adc47a3c8e (diff) | |
| download | qpid-python-408006d6d6543309b29d17eadb6df16fdd57fdf2.tar.gz | |
QPID-4953: recognise temp queue shorthand in 0-10 codepath
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1496985 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/MessagingSessionTests.cpp')
| -rw-r--r-- | cpp/src/tests/MessagingSessionTests.cpp | 25 |
1 files changed, 24 insertions, 1 deletions
diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp index 82c729cd72..b388f2c13a 100644 --- a/cpp/src/tests/MessagingSessionTests.cpp +++ b/cpp/src/tests/MessagingSessionTests.cpp @@ -521,7 +521,7 @@ struct DeletePolicyFixture : public MessagingFixture void test(Mode mode) { - qpid::messaging::Address address("#; " + getPolicy(mode)); + qpid::messaging::Address address("testqueue#; " + getPolicy(mode)); create(address); Sender s = session.createSender(address); @@ -1266,6 +1266,29 @@ QPID_AUTO_TEST_CASE(testConcurrentFetch) BOOST_CHECK(fetcher.result); } +QPID_AUTO_TEST_CASE(testSimpleRequestResponse) +{ + QueueFixture fix; + //create receiver on temp queue for responses (using shorthand for temp queue) + Receiver r1 = fix.session.createReceiver("#"); + //send request + Sender s1 = fix.session.createSender(fix.queue); + Message original("test-message"); + original.setSubject("test-subject"); + original.setReplyTo(r1.getAddress()); + s1.send(original); + + //receive request and send response + Receiver r2 = fix.session.createReceiver(fix.queue); + Message m = r2.fetch(Duration::SECOND * 5); + Sender s2 = fix.session.createSender(m.getReplyTo()); + s2.send(m); + m = r1.fetch(Duration::SECOND * 5); + fix.session.acknowledge(); + BOOST_CHECK_EQUAL(m.getContent(), original.getContent()); + BOOST_CHECK_EQUAL(m.getSubject(), original.getSubject()); +} + QPID_AUTO_TEST_SUITE_END() }} // namespace qpid::tests |