top-think/think-queue

在think-queue\src\queue\connector\Redis.php

Closed this issue · 1 comments

位置:62-69line
public function later($delay, $job, $data = '', $queue = null)
{
$payload = $this->createPayload($job, $data);

    $this->redis->zAdd($this->getQueue($queue) . ':delayed', time() + $delay, $payload);
    //添加返回
 return json_decode($payload, true)['id'];
}

解决Queue::later没有消息ID返回