|
|
@ -41,7 +41,6 @@ public class SendMqMsgUtils { |
|
|
|
} |
|
|
|
log.info("sendMsg param:{}", JSON.toJSONString(msg)); |
|
|
|
try { |
|
|
|
// TODO
|
|
|
|
ValidatorUtils.validateEntity(msg, DefaultGroup.class); |
|
|
|
} catch (ValidateException e) { |
|
|
|
return new Result<String>().error(e.getMsg()); |
|
|
@ -53,9 +52,8 @@ public class SendMqMsgUtils { |
|
|
|
int retryTime = 0; |
|
|
|
Result<String> result = null; |
|
|
|
do { |
|
|
|
retryTime++; |
|
|
|
result = HttpClientManager.getInstance().sendPostByHttps(msg.getRequestUrl(), JSON.toJSONString(msg)); |
|
|
|
log.info("sendMsg retryTime:{},result:{}", retryTime, JSON.toJSONString(result)); |
|
|
|
log.info("sendMsg retryTime:{},result:{}", retryTime++, JSON.toJSONString(result)); |
|
|
|
} while ((!result.success()) && retryTime < 2); |
|
|
|
|
|
|
|
if (result.success()) { |
|
|
|