From cea30bd45679ae39de64cb93e25d914abc937ba0 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Tue, 6 Apr 2010 19:08:28 +0000
Subject: QPID-664: added method to release messages

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@931275 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/client/amqp0_10/SessionImpl.cpp | 12 ++++++++++++
 1 file changed, 12 insertions(+)

(limited to 'cpp/src/qpid/client/amqp0_10/SessionImpl.cpp')

diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
index bb0a735fde..9efafb1d16 100644
--- a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
@@ -92,6 +92,11 @@ void SessionImpl::reject(qpid::messaging::Message& m)
     execute1<Reject>(m);
 }
 
+void SessionImpl::release(qpid::messaging::Message& m)
+{
+    execute1<Release>(m);
+}
+
 void SessionImpl::close()
 {
     //close all the senders and receivers (get copy of names and then
@@ -418,6 +423,13 @@ void SessionImpl::rejectImpl(qpid::messaging::Message& m)
     session.messageReject(set);
 }
 
+void SessionImpl::releaseImpl(qpid::messaging::Message& m)
+{
+    SequenceSet set;
+    set.add(MessageImplAccess::get(m).getInternalId());
+    session.messageRelease(set);
+}
+
 void SessionImpl::receiverCancelled(const std::string& name)
 {
     receivers.erase(name);
-- 
cgit v1.2.1