1 增加华之韵物流对接
@ -121,6 +121,7 @@ public class MqServiceImpl implements MqService {
return messagePostProcessor;
}, correlationData);
} catch (Exception e) {
e.printStackTrace();
//出现异常,这里将异常转化为自定义异常MsgException,主要是为了触发重试机制
throw MsgException.builder()
.failMsgEntity(FailMsgEntity.builder()