...
|
...
|
@@ -112,7 +112,7 @@ public abstract class AbstractMqListener<T> implements MessageListener { |
|
|
// 参数检测,不满足条件,隔一分钟再检查一次
|
|
|
Object checkResult = this.checkData(object, messageJsonObject.getAction());
|
|
|
if (checkResult == null) {
|
|
|
DataCheckLogger.warn("checkData fail, wait 60s ......");
|
|
|
DataCheckLogger.warn("checkData fail, wait 60s ...... , data is [{}]" , messageJsonObject);
|
|
|
TimeUnit.SECONDS.sleep(10);
|
|
|
}
|
|
|
checkResult = this.checkData(object, messageJsonObject.getAction());
|
...
|
...
|
|