diff options
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();
|