redis-queue 延遲隊列不消費,使用的官方源碼安裝
Redis::connection('house')->send('merchant-cancel-order', ['id' =>$orderInfo['id']], 3600);
隊列數(shù)據(jù):
配置文件:
使用webman 1.6.9 redis版本:7.2
你這隊列名和你上面send的對不上啊
一個merchant-cancel-order,一個order-push-hall, delay值也對不上啊,一個3600一個120
粘貼錯了,是這樣寫的。 Redis::connection('other')->send('order-push-hall', ['id' => $result->id], 120);
<?php
namespace app\queue\redis;
use app\api\model\Order;
use Webman\RedisQueue\Consumer;
//顯示到服務大廳
class OrderPushHall implements Consumer
{
// 要消費的隊列名
public $queue = 'order-push-hall';
// 連接名,對應 plugin/webman/redis-queue/redis.php 里的連接`
public $connection = 'other';
// 消費
public function consume($data)
{
Order::where('id', $data['id'])->update(['is_visible' => 0]);
return true;
}
}