activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1737421 - /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/branches/1.7.x/src/main/csharp/AdvisoryConsumer.cs
Date Fri, 01 Apr 2016 19:03:10 GMT
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);



Mime
View raw message