fix tests.

Author: makasim

pkg/redis/RedisSubscriptionConsumer.php

@@ -36,8 +36,8 @@ public function consume(int $timeout = 0): void
             throw new \LogicException('No subscribers');
         }
 
-        $timeout /= 1000;
-        $endAt = microtime(true) + $timeout;
+        $timeout = (int) ceil($timeout / 1000);
+        $endAt = time() + $timeout;
 
         $queueNames = [];
         foreach (array_keys($this->subscribers) as $queueName) {
@@ -55,7 +55,7 @@ public function consume(int $timeout = 0): void
              * @var PsrConsumer $consumer
              * @var callable    $processor
              */
-            $result = $this->context->getRedis()->brpop($currentQueueNames, $timeout ?: 5000);
+            $result = $this->context->getRedis()->brpop($currentQueueNames, $timeout ?: 5);
             if ($result) {
                 $message = RedisMessage::jsonUnserialize($result->getMessage());
                 list($consumer, $callback) = $this->subscribers[$result->getKey()];