summaryrefslogtreecommitdiff
path: root/cpp/src/tests/MessagingSessionTests.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-04-06 14:52:47 +0000
committerGordon Sim <gsim@apache.org>2010-04-06 14:52:47 +0000
commit8fddccd7efb73cd25376f5492ddb09ad7fa09e3b (patch)
tree2c2e7045eb1a4733fbb24a4f7106e96dca945ae0 /cpp/src/tests/MessagingSessionTests.cpp
parent48d21770c0c93551180043ddf27b1b7178382a4a (diff)
downloadqpid-python-8fddccd7efb73cd25376f5492ddb09ad7fa09e3b.tar.gz
QPID-664: added param to control synchronous send and acknowledge
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@931170 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/MessagingSessionTests.cpp')
-rw-r--r--cpp/src/tests/MessagingSessionTests.cpp12
1 files changed, 12 insertions, 0 deletions
diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp
index bdfb8b389c..e1c0a6bb16 100644
--- a/cpp/src/tests/MessagingSessionTests.cpp
+++ b/cpp/src/tests/MessagingSessionTests.cpp
@@ -231,6 +231,18 @@ QPID_AUTO_TEST_CASE(testSimpleSendReceive)
BOOST_CHECK_EQUAL(in.getContent(), out.getContent());
}
+QPID_AUTO_TEST_CASE(testSyncSendReceive)
+{
+ QueueFixture fix;
+ Sender sender = fix.session.createSender(fix.queue);
+ Message out("test-message");
+ sender.send(out, true);
+ Receiver receiver = fix.session.createReceiver(fix.queue);
+ Message in = receiver.fetch(Duration::IMMEDIATE);
+ fix.session.acknowledge(true);
+ BOOST_CHECK_EQUAL(in.getContent(), out.getContent());
+}
+
QPID_AUTO_TEST_CASE(testSendReceiveHeaders)
{
QueueFixture fix;