|
@@ -223,6 +223,12 @@ public class ContentServiceImpl implements ContentService {
|
|
submitTasks(submitTasksParam);
|
|
submitTasks(submitTasksParam);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
XxlJobLogger.log("record = {} error", record);
|
|
XxlJobLogger.log("record = {} error", record);
|
|
|
|
+ } finally {
|
|
|
|
+ try {
|
|
|
|
+ TimeUnit.SECONDS.sleep(2);
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
+ log.error(e.getMessage(), e);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
@@ -285,6 +291,12 @@ public class ContentServiceImpl implements ContentService {
|
|
TaskResultVO taskResultVO = submitTasks(submitTasksParam);
|
|
TaskResultVO taskResultVO = submitTasks(submitTasksParam);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
XxlJobLogger.log("record = {} error", record);
|
|
XxlJobLogger.log("record = {} error", record);
|
|
|
|
+ } finally {
|
|
|
|
+ try {
|
|
|
|
+ TimeUnit.SECONDS.sleep(2);
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
+ log.error(e.getMessage(), e);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
@@ -346,6 +358,12 @@ public class ContentServiceImpl implements ContentService {
|
|
TaskResultVO taskResultVO = submitTasks(submitTasksParam);
|
|
TaskResultVO taskResultVO = submitTasks(submitTasksParam);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
XxlJobLogger.log("record = {} error", record);
|
|
XxlJobLogger.log("record = {} error", record);
|
|
|
|
+ } finally {
|
|
|
|
+ try {
|
|
|
|
+ TimeUnit.SECONDS.sleep(2);
|
|
|
|
+ } catch (InterruptedException e) {
|
|
|
|
+ log.error(e.getMessage(), e);
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|