diff options
author | Charles E. Rolke <chug@apache.org> | 2010-10-29 17:23:49 +0000 |
---|---|---|
committer | Charles E. Rolke <chug@apache.org> | 2010-10-29 17:23:49 +0000 |
commit | 88d0fc0f70daab03c9302ffa5af30d551372dac2 (patch) | |
tree | b697794894beecbd97437bef3f38b5324940cbd0 /cpp | |
parent | 14faaa5492a64986ed8a8e9b235664f1fa7a4bc4 (diff) | |
download | qpid-python-88d0fc0f70daab03c9302ffa5af30d551372dac2.tar.gz |
QPID-2807 More flexible acknowledgement
The message-level Acknowledge in Cpp was not reflected in the .NET Messaging binding.
This commit adds the ack to the code and to the doc book session method mapping table.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1028859 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r-- | cpp/bindings/qpid/dotnet/src/Session.cpp | 10 | ||||
-rw-r--r-- | cpp/bindings/qpid/dotnet/src/Session.h | 2 |
2 files changed, 12 insertions, 0 deletions
diff --git a/cpp/bindings/qpid/dotnet/src/Session.cpp b/cpp/bindings/qpid/dotnet/src/Session.cpp index 6d40a27605..344c3b7d33 100644 --- a/cpp/bindings/qpid/dotnet/src/Session.cpp +++ b/cpp/bindings/qpid/dotnet/src/Session.cpp @@ -112,6 +112,16 @@ namespace Messaging { sessionp->acknowledge(sync);
}
+ void Session::Acknowledge(Message ^ message)
+ {
+ Acknowledge(message, false);
+ }
+
+ void Session::Acknowledge(Message ^ message, bool sync)
+ {
+ sessionp->acknowledge(*(message->NativeMessage), sync);
+ }
+
void Session::Reject(Message ^ message)
{
sessionp->::qpid::messaging::Session::reject(*(message->NativeMessage));
diff --git a/cpp/bindings/qpid/dotnet/src/Session.h b/cpp/bindings/qpid/dotnet/src/Session.h index d34289b1bb..aa42cf5668 100644 --- a/cpp/bindings/qpid/dotnet/src/Session.h +++ b/cpp/bindings/qpid/dotnet/src/Session.h @@ -104,6 +104,8 @@ namespace Messaging { void Rollback();
void Acknowledge();
void Acknowledge(bool sync);
+ void Acknowledge(Message ^ message);
+ void Acknowledge(Message ^ message, bool sync);
void Reject(Message ^);
void Release(Message ^);
void Sync();
|