Redis消息队列组件 redis-queue 的消费 Consumer 对象怎么记录 Exception?

isgbuddy

如 class TestConsumer implements Consumer 这样的消费对象方法中,如果抛出异常,似乎被什么默认事件处理了,不会抛出?这个怎么记录消费对象方法中抛出的 Exception?

1299 1 1
1个回答

walkor

消费过程出现异常,并且业务没有捕获这个异常,框架会认为是消费失败,放入重试队列,等待重试。如果你想记录异常,自己在consume()方法里加个try catch 吧

消费异常重试相关详情参见文档
https://www.workerman.net/doc/webman/queue/redis.html#%E9%85%8D%E7%BD%AE

  • isgbuddy 2021-12-24

    我已经在全局加了个 namespace support\exception; class Handler extends ExceptionHandler,consume() 抛出的异常没法抓住,其它在 namespace app\controller; 下的会在class Handler extends ExceptionHandler 抓住

  • walkor 2021-12-24

    那个异常处理只支持webman http服务,对于自定义进程没有作用

  • isgbuddy 2021-12-24

    哦哦,了解了,感谢

年代过于久远,无法发表回答
🔝