Fix ping to check each connection, not only first one

webmake · Nov 22, 2018 · 72d4097 · 72d4097
1 parent 973ac0f
commit 72d4097
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/enqueue-bundle/Consumption/Extension/DoctrinePingConnectionExtension.php b/pkg/enqueue-bundle/Consumption/Extension/DoctrinePingConnectionExtension.php
@@ -31,7 +31,7 @@ public function onMessageReceived(MessageReceived $context): void
             }
 
             if ($connection->ping()) {
-                return;
+                continue;
             }
 
             $context->getLogger()->debug(