Avoid receiveNoWait when only one subscriber

Author: deguif

Diff for: pkg/enqueue/Consumption/FallbackSubscriptionConsumer.php

@@ -13,21 +13,16 @@ final class FallbackSubscriptionConsumer implements SubscriptionConsumer
      *
      * @var array
      */
-    private $subscribers;
+    private $subscribers = [];
 
     /**
      * @var int
      */
     private $idleTime = 0;
 
-    public function __construct()
-    {
-        $this->subscribers = [];
-    }
-
     public function consume(int $timeout = 0): void
     {
-        if (empty($this->subscribers)) {
+        if (!$subscriberCount = \count($this->subscribers)) {
             throw new \LogicException('No subscribers');
         }
 
@@ -41,13 +36,13 @@ public function consume(int $timeout = 0): void
              * @var callable $processor
              */
             foreach ($this->subscribers as $queueName => list($consumer, $callback)) {
-                $message = $consumer->receiveNoWait();
+                $message = 1 === $subscriberCount ? $consumer->receive((int) ($timeout * 1000)) : $consumer->receiveNoWait();
 
                 if ($message) {
                     if (false === call_user_func($callback, $message, $consumer)) {
                         return;
                     }
-                } else {
+                } elseif (1 !== $subscriberCount) {
                     if ($timeout && microtime(true) >= $endAt) {
                         return;
                     }