public class ConsumerListenerService : BackgroundServiceBase
    {
        private readonly IEnumerable<ConsumerBase> _consumers;

        public ConsumerListenerService(params ConsumerBase[] consumers)
        {
            _consumers = consumers;
        }

        protected override Task ExecuteAsync(CancellationToken stoppingToken)
        {
            foreach (var consumer in _consumers)
            {
                consumer.Start();
            }

            return Task.CompletedTask;
        }

        public override Task StopAsync(CancellationToken cancellationToken)
        {
            foreach (var consumer in _consumers)
            {
                consumer.Stop();
            }

            return Task.CompletedTask;
        }
    }