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 2017/03/08 23:12:48 UTC
[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)
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 <ta...@apache.org>
Authored: Fri Apr 1 19:03:10 2016 +0000
Committer: Timothy A. Bish <ta...@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);