private static async Task ConsumeMessageFromSubscription()

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

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

    private static async Task ConsumeMessageFromSubscription(string topicName,string subscriptionName)
    {
        Console.WriteLine($"Rcv_Sub {subscriptionName} Begin");

        //  Receive on Sub 1
        var client1 = new ServiceBusClient(_connectionString);
        var opt1 = new ServiceBusProcessorOptions();
        opt1.ReceiveMode = ServiceBusReceiveMode.PeekLock;
        var processor1 = client1.CreateProcessor(topicName, subscriptionName, opt1);

        processor1.ProcessMessageAsync += MessageHandler;
        processor1.ProcessErrorAsync += ErrorHandler;

        await processor1.StartProcessingAsync();

        await Task.Delay(TimeSpan.FromSeconds(5));

        await processor1.StopProcessingAsync();
        await processor1.DisposeAsync();
        await client1.DisposeAsync();
        Console.WriteLine($"Rcv_Sub {subscriptionName} End");
    }