public Task AddAsync()

in extension/WebJobs.Extensions.RabbitMQ/Bindings/RabbitMQAsyncCollector.cs [25:35]

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

    public Task AddAsync(ReadOnlyMemory<byte> message, CancellationToken cancellationToken = default)
    {
        this.logger.LogDebug("Adding message to batch for publishing...");

        lock (this.context.Service.PublishBatchLock)
        {
            this.context.Service.BasicPublishBatch.Add(exchange: string.Empty, routingKey: this.context.ResolvedAttribute.QueueName, mandatory: false, properties: null, body: message);
        }

        return Task.CompletedTask;
    }