workerman/redis-queue的onConsumeFailure消费失败回调没有

Destiny

问题描述

workerman/redis-queue的onConsumeFailure消费失败回调没有

包版本号

"webman/redis": "^2.1",
"webman/redis-queue": "^1.3",

webman/redis-queue包里面的接口也有消费的接口 没有失败回调的接口

namespace Webman\RedisQueue;

/**
 * Interface Consumer
 * @package Webman\RedisQueue
 */
interface Consumer
{
    public function consume($data);
}

这个是workman/redis-queue的 有失败回调

截图

76 2 0
2个回答

orangeFan

截图

  • 暂无评论

onConsumeFailure 是其他开发者pr添加的,是可选的实现,不好直接定义到interface 里,否则老用户升级就报错了。

  • 暂无评论
🔝