commit 9adb65657365375cba3bbe9b95643e9df62e6037
author Timothy A. Bish <tabish@apache.org> Fri Apr 01 19:01:57 2016 +0000
committer Timothy A. Bish <tabish@apache.org> Fri Apr 01 19:01:57 2016 +0000
tree dadc3a080084b8caa8f9f2d2cd06f7c773fbb12d
parent 37c86bdc07289cd995a3c4d4ab12992bfafc9da0

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)

src/main/csharp/AdvisoryConsumer.cs

diff --git a/src/main/csharp/AdvisoryConsumer.cs b/src/main/csharp/AdvisoryConsumer.cs
index 8f8f4f5..90c9046 100644
--- a/src/main/csharp/AdvisoryConsumer.cs
+++ b/src/main/csharp/AdvisoryConsumer.cs
@@ -79,7 +79,7 @@
                     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);