activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject [45/50] [abbrv] activemq-nms-openwire git commit: 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)
Date Wed, 08 Mar 2017 23:12:47 GMT
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)



Project: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/commit/9adb6565
Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/tree/9adb6565
Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/diff/9adb6565

Branch: refs/heads/master
Commit: 9adb65657365375cba3bbe9b95643e9df62e6037
Parents: 37c86bd
Author: Timothy A. Bish <tabish@apache.org>
Authored: Fri Apr 1 19:01:57 2016 +0000
Committer: Timothy A. Bish <tabish@apache.org>
Committed: Fri Apr 1 19:01:57 2016 +0000

----------------------------------------------------------------------
 src/main/csharp/AdvisoryConsumer.cs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/blob/9adb6565/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 @@ 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