public static async Task ProcessMessage_RabbitMQAsyncCollector()

in extension/WebJobs.Extensions.RabbitMQ.Samples/RabbitMQSamples.cs [50:58]

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

    public static async Task ProcessMessage_RabbitMQAsyncCollector(
        [QueueTrigger(@"samples-rabbitmq-messages")] string message,
        [RabbitMQ(QueueName = "queue")] IAsyncCollector<byte[]> messages,
        ILogger logger)
    {
        logger.LogInformation("Received queue trigger");
        byte[] messageInBytes = Encoding.UTF8.GetBytes(message);
        await messages.AddAsync(messageInBytes).ConfigureAwait(false);
    }