diff --git a/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java b/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java index a54be3907..ae076bfd3 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-base/src/main/java/com/logpm/factorydata/base/service/impl/MqServiceImpl.java @@ -121,6 +121,7 @@ public class MqServiceImpl implements MqService { return messagePostProcessor; }, correlationData); } catch (Exception e) { + e.printStackTrace(); //出现异常,这里将异常转化为自定义异常MsgException,主要是为了触发重试机制 throw MsgException.builder() .failMsgEntity(FailMsgEntity.builder()