修正 RedisQueueDriver、AMQPQueueDriver 的 pop 方法定义

Author: Yurunsoft

src/Driver/IQueueDriver.php

@@ -24,6 +24,8 @@ public function push(IMessage $message, float $delay = 0, array $options = []):
 
     /**
      * 从队列弹出一个消息.
+     *
+     * @param float $timeout 超时时间，单位：秒。值小于等于0时立即返回结果
      */
     public function pop(float $timeout = 0): ?IMessage;
 

src/Driver/RedisQueueDriver.php

@@ -51,15 +51,15 @@ public function __construct(string $name, array $config = [])
     }
 
     /**
-     * 获取队列名称.
+     * {@inheritDoc}
      */
     public function getName(): string
     {
         return $this->name;
     }
 
     /**
-     * 推送消息到队列，返回消息ID.
+     * {@inheritDoc}
      */
     public function push(IMessage $message, float $delay = 0, array $options = []): string
     {
@@ -158,11 +158,9 @@ public function push(IMessage $message, float $delay = 0, array $options = []):
     }
 
     /**
-     * 从队列弹出一个消息.
-     *
-     * @param float $timeout 超时时间，单位：秒。值是-1时立即返回结果
+     * {@inheritDoc}
      */
-    public function pop(float $timeout = -1): ?IMessage
+    public function pop(float $timeout = 0): ?IMessage
     {
         $time = $useTime = 0;
         do
@@ -246,7 +244,7 @@ public function pop(float $timeout = -1): ?IMessage
     }
 
     /**
-     * 删除一个消息.
+     * {@inheritDoc}
      */
     public function delete(IMessage $message): bool
     {
@@ -286,9 +284,7 @@ public function delete(IMessage $message): bool
     }
 
     /**
-     * 清空队列.
-     *
-     * @param int|int[]|null $queueType 清空哪个队列，默认为全部
+     * {@inheritDoc}
      */
     public function clear($queueType = null): void
     {
@@ -309,7 +305,7 @@ public function clear($queueType = null): void
     }
 
     /**
-     * 将消息标记为成功
+     * {@inheritDoc}
      */
     public function success(IMessage $message): int
     {
@@ -346,7 +342,7 @@ public function success(IMessage $message): int
     }
 
     /**
-     * 将消息标记为失败.
+     * {@inheritDoc}
      */
     public function fail(IMessage $message, bool $requeue = false): int
     {
@@ -393,7 +389,7 @@ public function fail(IMessage $message, bool $requeue = false): int
     }
 
     /**
-     * 获取队列状态
+     * {@inheritDoc}
      */
     public function status(): QueueStatus
     {
@@ -420,9 +416,7 @@ public function status(): QueueStatus
     }
 
     /**
-     * 将失败消息恢复到队列.
-     *
-     * 返回恢复数量
+     * {@inheritDoc}
      */
     public function restoreFailMessages(): int
     {
@@ -456,9 +450,7 @@ public function restoreFailMessages(): int
     }
 
     /**
-     * 将超时消息恢复到队列.
-     *
-     * 返回恢复数量
+     * {@inheritDoc}
      */
     public function restoreTimeoutMessages(): int
     {