|
@ -131,12 +131,12 @@ public class SystemMessageServiceImpl implements SystemMessageService { |
|
|
logger.info("【发送MQ系统消息】-发送到MQ成功"); |
|
|
logger.info("【发送MQ系统消息】-发送到MQ成功"); |
|
|
} catch (MQClientException e) { |
|
|
} catch (MQClientException e) { |
|
|
String errorStackTrace = ExceptionUtils.getErrorStackTrace(e); |
|
|
String errorStackTrace = ExceptionUtils.getErrorStackTrace(e); |
|
|
logger.error("【发送MQ系统消息】发送系统MQ消息失败,堆栈信息:{}", errorStackTrace); |
|
|
logger.error("【发送MQ系统消息】发送系统MQ消息失败,MQ中间件异常请检查:{}", errorStackTrace); |
|
|
|
|
|
|
|
|
// 清理阻塞中的消息缓存
|
|
|
// 清理阻塞中的消息缓存
|
|
|
redisUtils.delete(pendingMsgKey); |
|
|
redisUtils.delete(pendingMsgKey); |
|
|
|
|
|
|
|
|
throw new RenException(EpmetErrorCode.SYSTEM_MQ_MSG_SEND_FAIL.getCode()); |
|
|
throw new RenException(EpmetErrorCode.SYSTEM_MQ_MSG_SEND_FAIL.getCode(),e.getErrorMessage()); |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
String errorStackTrace = ExceptionUtils.getErrorStackTrace(e); |
|
|
String errorStackTrace = ExceptionUtils.getErrorStackTrace(e); |
|
|
logger.error("【发送MQ系统消息】发送系统MQ消息失败,堆栈信息:{}", errorStackTrace); |
|
|
logger.error("【发送MQ系统消息】发送系统MQ消息失败,堆栈信息:{}", errorStackTrace); |
|
|