tests/MassTransit.Benchmark/InMemoryOptionSet.cs - develop - vshmidt/masstransit

tests/MassTransit.Benchmark/InMemoryOptionSet.cs

24 строки591 B

Chris Patterson

Added Kafka to benchmark to test throughput/latency.

24 дек 2022, 04:26

24 дек 2022, 04:2620d61f6

namespace MassTransitBenchmark
{
    using System;
    using NDesk.Options;


    public class InMemoryOptionSet :
        OptionSet
    {
        public InMemoryOptionSet()
        {
            Add<int>("limit=", "The transport concurrency limit", x => TransportConcurrencyLimit = x);

            TransportConcurrencyLimit = Environment.ProcessorCount;
        }

        public int TransportConcurrencyLimit { get; private set; }

        public void ShowOptions()
        {
            Console.WriteLine("Transport Concurrency Limit: {0}", TransportConcurrencyLimit);
        }
    }
}