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

2 files changed, 22 insertions, 0 deletions

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);
diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.h b/cpp/src/qpid/client/amqp0_10/SessionImpl.h
index ab29d2c1e1..5f9b23fb14 100644
--- a/cpp/src/qpid/client/amqp0_10/SessionImpl.h
+++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.h
@@ -60,6 +60,7 @@ class SessionImpl : public qpid::messaging::SessionImpl
     void rollback();
     void acknowledge(bool sync);
     void reject(qpid::messaging::Message&);
+    void release(qpid::messaging::Message&);
     void close();
     void sync();
     void flush();
@@ -123,6 +124,7 @@ class SessionImpl : public qpid::messaging::SessionImpl
     void rollbackImpl();
     void acknowledgeImpl();
     void rejectImpl(qpid::messaging::Message&);
+    void releaseImpl(qpid::messaging::Message&);
     void closeImpl();
     void syncImpl();
     void flushImpl();
@@ -177,6 +179,14 @@ class SessionImpl : public qpid::messaging::SessionImpl
         Reject(SessionImpl& i, qpid::messaging::Message& m) : Command(i), message(m) {}
         void operator()() { impl.rejectImpl(message); }
     };
+
+    struct Release : Command
+    {
+        qpid::messaging::Message& message;
+
+        Release(SessionImpl& i, qpid::messaging::Message& m) : Command(i), message(m) {}
+        void operator()() { impl.releaseImpl(message); }
+    };
     
     struct CreateSender;
     struct CreateReceiver;