using System; using System.Collections.Generic; using System.Threading.Tasks; namespace Pole.EventBus.RabbitMQ { public class RabbitConsumer : Consumer { public RabbitConsumer( Func, Task> batchEventHandlers) : base( new List, Task>> { batchEventHandlers }) { } public RabbitEventBus EventBus { get; set; } public QueueInfo QueueInfo { get; set; } public ConsumerOptions Config { get; set; } } }