This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 12ef82697b098ad61a7c17da1fdd3db020c808a6 Author: colprog <[email protected]> AuthorDate: Sun Dec 25 04:06:46 2022 +0800 dotnet: allow changing SimpleConsumer polling time --- csharp/rocketmq-client-csharp/SimpleConsumer.cs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/csharp/rocketmq-client-csharp/SimpleConsumer.cs b/csharp/rocketmq-client-csharp/SimpleConsumer.cs index 5dd3a03b..ff92044f 100644 --- a/csharp/rocketmq-client-csharp/SimpleConsumer.cs +++ b/csharp/rocketmq-client-csharp/SimpleConsumer.cs @@ -196,7 +196,7 @@ namespace Org.Apache.Rocketmq } } - public async Task<List<Message>> Receive(int batchSize, TimeSpan invisibleDuration) + public async Task<List<Message>> Receive(int batchSize, TimeSpan invisibleDuration, TimeSpan? awaitDuration = null) { var messageQueue = NextQueue(); if (null == messageQueue) @@ -225,8 +225,7 @@ namespace Org.Apache.Rocketmq var metadata = new Metadata(); Signature.Sign(this, metadata); - var timeout = ClientSettings.Subscription.LongPollingTimeout - .ToTimeSpan() + var timeout = (awaitDuration ?? ClientSettings.Subscription.LongPollingTimeout.ToTimeSpan()) .Add(this.RequestTimeout); return await Manager.ReceiveMessage(targetUrl, metadata, request, timeout);
