public async Task ChangeInvisibleDuration()

in rocketmq-client-csharp/SimpleConsumer.cs [213:233]


        public async Task ChangeInvisibleDuration(Message message, TimeSpan invisibleDuration)
        {
            var request = new rmq.ChangeInvisibleDurationRequest();
            request.Group = new rmq.Resource();
            request.Group.ResourceNamespace = ResourceNamespace;
            request.Group.Name = _group;

            request.Topic = new rmq.Resource();
            request.Topic.ResourceNamespace = ResourceNamespace;
            request.Topic.Name = message.Topic;

            request.ReceiptHandle = message._receiptHandle;
            request.MessageId = message.MessageId;
            
            request.InvisibleDuration = Duration.FromTimeSpan(invisibleDuration);

            var targetUrl = message._sourceHost;
            var metadata = new Metadata();
            Signature.sign(this, metadata);
            await Manager.ChangeInvisibleDuration(targetUrl, metadata, request, RequestTimeout);
        }