Author: chug Date: Fri Jun 17 21:23:50 2011 New Revision: 1137034 URL: http://svn.apache.org/viewvc?rev=1137034&view=rev Log: QPID-3200 Ability to acknowledge all messages up to and including a given message for a Session .NET Binding keeps up with additions to the Messaging package.
Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.cpp qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.h Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.cpp URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.cpp?rev=1137034&r1=1137033&r2=1137034&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.cpp (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.cpp Fri Jun 17 21:23:50 2011 @@ -248,6 +248,31 @@ namespace Messaging { } } + void Session::AcknowledgeUpTo(Message ^ message) + { + AcknowledgeUpTo(message, false); + } + + void Session::AcknowledgeUpTo(Message ^ message, bool sync) + { + System::Exception ^ newException = nullptr; + + try + { + sessionp->acknowledgeUpTo(*(message->NativeMessage), sync); + } + catch (const ::qpid::types::Exception & error) + { + String ^ errmsg = gcnew String(error.what()); + newException = gcnew QpidException(errmsg); + } + + if (newException != nullptr) + { + throw newException; + } + } + void Session::Reject(Message ^ message) { System::Exception ^ newException = nullptr; Modified: qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.h URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.h?rev=1137034&r1=1137033&r2=1137034&view=diff ============================================================================== --- qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.h (original) +++ qpid/trunk/qpid/cpp/bindings/qpid/dotnet/src/Session.h Fri Jun 17 21:23:50 2011 @@ -104,6 +104,8 @@ namespace Messaging { void Acknowledge(bool sync); void Acknowledge(Message ^ message); void Acknowledge(Message ^ message, bool sync); + void AcknowledgeUpTo(Message ^ message); + void AcknowledgeUpTo(Message ^ message, bool sync); void Reject(Message ^); void Release(Message ^); void Sync(); --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:commits-subscr...@qpid.apache.org