activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject [46/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:48 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/d1ee5ba0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/tree/d1ee5ba0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-nms-openwire/diff/d1ee5ba0

Branch: refs/heads/1.7.x
Commit: d1ee5ba0b552584090559034018f197d4fa4c27a
Parents: 399c1db
Author: Timothy A. Bish <tabish@apache.org>
Authored: Fri Apr 1 19:03:10 2016 +0000
Committer: Timothy A. Bish <tabish@apache.org>
Committed: Fri Apr 1 19:03:10 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/d1ee5ba0/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