internal Task PublishAsync()

in extension/WebJobs.Extensions.RabbitMQ/Bindings/RabbitMQAsyncCollector.cs [42:53]

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

    internal Task PublishAsync()
    {
        this.logger.LogDebug("Publishing messages to queue.");

        lock (this.context.Service.PublishBatchLock)
        {
            this.context.Service.BasicPublishBatch.Publish();
            this.context.Service.ResetPublishBatch();
        }

        return Task.CompletedTask;
    }