summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/MessagingSessionTests.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-04-06 19:08:28 +0000
committerGordon Sim <gsim@apache.org>2010-04-06 19:08:28 +0000
commit24816ab849015f212eb49963c3e08b99dfa700fe (patch)
tree508d0b53cd6a817417c4de029a7a2fb39d94d922 /qpid/cpp/src/tests/MessagingSessionTests.cpp
parent0e4a47f12834b203a77b9802afa919a562062114 (diff)
downloadqpid-python-24816ab849015f212eb49963c3e08b99dfa700fe.tar.gz
QPID-664: added method to release messages
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@931275 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/MessagingSessionTests.cpp')
-rw-r--r--qpid/cpp/src/tests/MessagingSessionTests.cpp15
1 files changed, 15 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/MessagingSessionTests.cpp b/qpid/cpp/src/tests/MessagingSessionTests.cpp
index e1c0a6bb16..6341ef3f28 100644
--- a/qpid/cpp/src/tests/MessagingSessionTests.cpp
+++ b/qpid/cpp/src/tests/MessagingSessionTests.cpp
@@ -857,6 +857,21 @@ QPID_AUTO_TEST_CASE(testTx)
BOOST_CHECK(!receiver2.fetch(in, Duration::IMMEDIATE));
}
+QPID_AUTO_TEST_CASE(testRelease)
+{
+ 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 m1 = receiver.fetch(Duration::IMMEDIATE);
+ fix.session.release(m1);
+ Message m2 = receiver.fetch(Duration::SECOND * 1);
+ BOOST_CHECK_EQUAL(m1.getContent(), out.getContent());
+ BOOST_CHECK_EQUAL(m1.getContent(), m2.getContent());
+ fix.session.acknowledge(true);
+}
+
QPID_AUTO_TEST_SUITE_END()
}} // namespace qpid::tests