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 2016/04/01 21:03:10 UTC
svn commit: r1737421 -
/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs
Author: tabish
Date: Fri Apr 1 19:03:10 2016
New Revision: 1737421
URL: http://svn.apache.org/viewvc?rev=1737421&view=rev
Log:
AdvisoryConsumer not sending back acks correctly leading to stall in receiving new advisory messages.
Fixes [AMQNET-AMQNET-522]. (See https://issues.apache.org/jira/browse/AMQNET-AMQNET-522)
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs?rev=1737421&r1=1737420&r2=1737421&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs Fri Apr 1 19:03:10 2016
@@ -79,7 +79,7 @@ namespace Apache.NMS.ActiveMQ
ack.AckType = (byte)AckType.ConsumedAck;
ack.ConsumerId = messageDispatch.ConsumerId;
ack.Destination = messageDispatch.Destination;
- ack.FirstMessageId = messageDispatch.Message.MessageId;
+ ack.LastMessageId = messageDispatch.Message.MessageId;
ack.MessageCount = deliveredCounter;
this.connection.Oneway(ack);