__construct($data = [])
{
$this->data['consumer_params'] = $data;
}
/** ----- 生产者相关\Webman\RedisQueue\Redis::send($this->queue, $pushData, $this->delay);
}
/** ----- 生产者相关消费逻辑处置函数
* @param $data
*/
abstract protected function handle($data);
/**
* 事件处理getTrace()]));
return;
}
$this->event($data);
}
/**
* 消费失败回调