|
|
@@ -76,7 +76,7 @@ public class taskJob {
|
|
|
/**
|
|
|
* 同步数据失败重新消费
|
|
|
*/
|
|
|
- @Scheduled(fixedDelay = 1000 * 60 % 5)
|
|
|
+ @Scheduled(fixedDelay = 1000 * 60 * 5)
|
|
|
public void tradeRepeatEntry(){
|
|
|
List<KxsDtsErrorLog> list = kxsDtsErrorLogService.list(Wrappers.<KxsDtsErrorLog>lambdaQuery().eq(KxsDtsErrorLog::getOperation, OperationType.INSERT).last("limit 100"));
|
|
|
|