private static async Task ProcessMessagesAsync()

in tools/scale-testing/MessageHandler/Program.cs [102:132]

27 lines of code
9 McCabe index (conditional complexity)


        private static async Task ProcessMessagesAsync(Message message, CancellationToken token)
        {
            // Process the message.
            Console.WriteLine($"Received message: SequenceNumber:{message.SystemProperties.SequenceNumber} Body:{Encoding.UTF8.GetString(message.Body)}");

            switch (s_topicName)
            {
                case KnownTopics.StowRs:
                case KnownTopics.StowRsTest:
                    await Stow(message, token);
                    break;
                case KnownTopics.WadoRs:
                case KnownTopics.WadoRsTest:
                    await Wado(message, token);
                    break;
                case KnownTopics.WadoRsMetadata:
                case KnownTopics.WadoRsMetadataTest:
                    await WadoMetadata(message, token);
                    break;
                case KnownTopics.Qido:
                case KnownTopics.QidoTest:
                    await Qido(message, token);
                    break;
                default:
                    System.Diagnostics.Trace.TraceError("Unsupported run type!");
                    break;
            }

            // Complete the message so that it is not received again.
            await s_subscriptionClient.CompleteAsync(message.SystemProperties.LockToken);
        }