queueClient

属性

BrokerInterface $queueClient

含义

消息中间件，默认使用redis中间件。

扩展

//自定义消息中间件
$worker->bindQueueClient(function(){
    //在这里实现自定义消息中间件
    //注意必须实现对应的 BrokerInterface 接口
    //关于接口说明详见 "附录指南 --> 接口原型" 章节
}, $args1, ..., $argsN);

//使用内置的单机版php消息队列
$worker->bindQueueClient("php", $args1, ..., $argsN);

举栗

$worker->queueClient->llen('task');