public async Task Ack()

in rocketmq-client-csharp/SimpleConsumer.cs [191:211]

• 18 lines of code
• 1 McCabe index (conditional complexity)

        public async Task Ack(Message message)
        {
            var request = new rmq.AckMessageRequest();
            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;
            
            var entry = new rmq.AckMessageEntry();
            request.Entries.Add(entry);
            entry.MessageId = message.MessageId;
            entry.ReceiptHandle = message._receiptHandle;

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