|
|
@@ -86,7 +86,11 @@ public class RedissonDelayMessageManager implements DelayMessageManager {
|
|
|
Optional<DelayMessageHandler> delayMessageHandler = handlers.stream().filter(handler -> ObjectUtil.equals(message.getHandlerId(), handler.getId()))
|
|
|
.findFirst()
|
|
|
.map(handler -> {
|
|
|
- handler.handle(message);
|
|
|
+ try {
|
|
|
+ handler.handle(message);
|
|
|
+ }catch (Exception e){
|
|
|
+ log.error("redisson延迟队列中,消费数据【{}】失败,",JSONUtil.toJsonStr(message), e);
|
|
|
+ }
|
|
|
return handler;
|
|
|
});
|
|
|
if(!delayMessageHandler.isPresent()){
|