Keeping the responsibility for creating parallel listeners on Listeni…

…ngAgent and not in Rabbit MQ itself. Closes GH-1152
JasperFx · Dec 2, 2024 · 8f9a716 · 8f9a716
1 parent e3906fd
commit 8f9a716
Showing 1 changed file with 0 additions and 13 deletions.
diff --git 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<IListener> BuildListenerAsync(IWolverineRuntime runtime,
 
     private async Task<IListener> buildListener(IWolverineRuntime runtime, IReceiver receiver, RabbitMqQueue queue)
     {
-        if (queue.ListenerCount > 1)
-        {
-            var listeners = new List<RabbitMqListener>(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;