fix: update ReceiptHandle after ChangeInvisibleDuration call

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
apache · May 28, 2024 · 39a7b35 · 39a7b35
1 parent 0149785
commit 39a7b35
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/csharp/rocketmq-client-csharp/MessageView.cs b/csharp/rocketmq-client-csharp/MessageView.cs
@@ -31,7 +31,7 @@ public class MessageView
         private static readonly ILogger Logger = MqLogManager.CreateLogger<MessageView>();
 
         internal readonly MessageQueue MessageQueue;
-        internal readonly string ReceiptHandle;
+        internal string ReceiptHandle;
         private readonly long _offset;
         private readonly bool _corrupted;
 

diff --git a/csharp/rocketmq-client-csharp/SimpleConsumer.cs b/csharp/rocketmq-client-csharp/SimpleConsumer.cs
@@ -220,6 +220,12 @@ public async void ChangeInvisibleDuration(MessageView messageView, TimeSpan invi
             var invocation = await ClientManager.ChangeInvisibleDuration(messageView.MessageQueue.Broker.Endpoints,
                 request, ClientConfig.RequestTimeout);
             StatusChecker.Check(invocation.Response.Status, request, invocation.RequestId);
+
+            // ReceiptHandle might have been updated after its invisible duration is changed.
+            if (invocation.Response.Status.Code == Proto.Code.Ok)
+            {
+                messageView.ReceiptHandle = invocation.Response.ReceiptHandle;
+            }
         }