diff --git a/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqTransport.cs b/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqTransport.cs index 631246d7..950f3810 100644 --- a/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqTransport.cs +++ b/src/Transports/RabbitMQ/Wolverine.RabbitMQ/Internal/RabbitMqTransport.cs @@ -365,19 +365,6 @@ public async ValueTask BuildListenerAsync(IWolverineRuntime runtime, private async Task buildListener(IWolverineRuntime runtime, IReceiver receiver, RabbitMqQueue queue) { - if (queue.ListenerCount > 1) - { - var listeners = new List(queue.ListenerCount); - for (var i = 0; i < queue.ListenerCount; i++) - { - var listener = new RabbitMqListener(runtime, queue, this, receiver); - await listener.CreateAsync(); - listeners.Add(listener); - } - - return new ParallelListener(queue.Uri, listeners); - } - var singleListener = new RabbitMqListener(runtime, queue, this, receiver); await singleListener.CreateAsync(); return singleListener;