public static async Task ConsumeMessageFromDefaultQueue()

in Sample-Code-Snippets/NET/ServiceBus.Emulator.Console.Sample/ServiceBus.Emulator.Console.Sample/Program.cs [54:89]

27 lines of code
3 McCabe index (conditional complexity)


    public static async Task ConsumeMessageFromDefaultQueue()
    {
        string queueName = "queue.1";

        var client = new ServiceBusClient(_connectionString);

        ServiceBusReceiverOptions opt = new ServiceBusReceiverOptions
        {
            ReceiveMode = ServiceBusReceiveMode.PeekLock,
        };

        ServiceBusReceiver receiver = client.CreateReceiver(queueName, opt);

        while (true)
        {
            ServiceBusReceivedMessage message = await receiver.ReceiveMessageAsync(TimeSpan.FromSeconds(5));
            if (message != null)
            {
                // Process the message
                Console.WriteLine($"Received message: {Encoding.UTF8.GetString(message.Body)}");

                // Complete the message to remove it from the queue
                await receiver.CompleteMessageAsync(message);
            }
            else
            {
                Console.WriteLine("No messages received.");
                break;
            }
        }

        Console.WriteLine("Done receiving.");

        await receiver.DisposeAsync();
        await client.DisposeAsync();
    }