hyperf / async-queue Goto Github PK

@AsyncQueueMessage

Job的handle里的异常好像不会抛到配置文件exceptions.php，这里面相关的异常捕获里处理。
在handle里使用try catch可正常使用

如题

比如使用队列来更新数据库中的记录， 队列中的对象有时候会出现同一个的 class 的不同 mutation，不同的mutation 示例实际上只有处于队列末端的元素是最近的一次更新，其他的 mutation 可以忽略掉，甚至不调用 handle 进行处理，因此队列中需要根据 key 的来维护一个唯一性的元素。

'pool' => 'default'

直接报错了

报错信息：
Class "Hyperf\Coroutine\Concurrent" not found in /opt/vendor/hyperf/async-queue/src/Driver/Driver.php:47

降到 v3.0.15 是 引用的 use Hyperf\Utils\Coroutine\Concurrent; 是OK的

不同的job执行耗时不同，如果在config文件里面统一配置太不灵活了，希望可以在job里面类似于maxAttempts一样可以单独配置