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:47 UTC
[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)
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 <ta...@apache.org>
Authored: Fri Apr 1 19:01:57 2016 +0000
Committer: Timothy A. Bish <ta...@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);