workerman/redis-queue的onConsumeFailure消费失败回调没有
"webman/redis": "^2.1",
"webman/redis-queue": "^1.3",
namespace Webman\RedisQueue;
/**
* Interface Consumer
* @package Webman\RedisQueue
*/
interface Consumer
{
public function consume($data);
}

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