|
|
@@ -69,7 +69,7 @@ public class RedisDelayedQueueUtil {
|
|
|
CLIENT.getDelayedQueue(blockingDeque);
|
|
|
return (T) blockingDeque.take();
|
|
|
} catch (InterruptedException e) {
|
|
|
- LogUtils.WS_MSG_RETRY_LOG.error("获取延时队列失败,队列键:{}, 失败原因:{}", queueCode, e.getMessage());
|
|
|
+ LogUtils.WS_MSG_RETRY_LOG.error("获取延时队列失败,队列键:{}, 失败原因:{}", queueCode, e.getCause());
|
|
|
throw new RuntimeException(e);
|
|
|
}
|
|
|
}
|