You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2009/10/30 15:36:07 UTC
svn commit: r831315 - in
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp:
MessageConsumer.cs Session.cs
Author: tabish
Date: Fri Oct 30 14:36:06 2009
New Revision: 831315
URL: http://svn.apache.org/viewvc?rev=831315&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-202
Client ack operates on the Session not just the source consumer.
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs?rev=831315&r1=831314&r2=831315&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/MessageConsumer.cs Fri Oct 30 14:36:06 2009
@@ -357,7 +357,7 @@
{
this.CheckClosed();
Tracer.Debug("Sending Client Ack:");
- this.Acknowledge();
+ this.session.Acknowledge();
}
public void Start()
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=831315&r1=831314&r2=831315&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Fri Oct 30 14:36:06 2009
@@ -794,7 +794,7 @@
{
lock(this.consumers.SyncRoot)
{
- foreach(MessageConsumer consumer in this.consumers)
+ foreach(MessageConsumer consumer in this.consumers.Values)
{
consumer.Acknowledge();
}