Browse Source

add sleep confiug

supeng 16 hours ago
parent
commit
30d376e1ba

+ 5 - 4
content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/service/impl/ContentServiceImpl.java

@@ -95,7 +95,8 @@ public class ContentServiceImpl implements ContentService {
 
 
     private static final Integer EXPIRE_DAYS = 7;
     private static final Integer EXPIRE_DAYS = 7;
 
 
-    private static final long RECORD_SLEEP = 6;
+    @Value("${old.version.video.understanding.record.sleep:6}")
+    private Long recordSleep;
 
 
     @Autowired
     @Autowired
     private OldVersionRemainVideoUnderstandingProducer oldVersionRemainVideoUnderstandingProducer;
     private OldVersionRemainVideoUnderstandingProducer oldVersionRemainVideoUnderstandingProducer;
@@ -227,7 +228,7 @@ public class ContentServiceImpl implements ContentService {
                     XxlJobLogger.log("record = {} error", record);
                     XxlJobLogger.log("record = {} error", record);
                 } finally {
                 } finally {
                     try {
                     try {
-                        TimeUnit.SECONDS.sleep(RECORD_SLEEP);
+                        TimeUnit.SECONDS.sleep(recordSleep);
                     } catch (InterruptedException e) {
                     } catch (InterruptedException e) {
                         log.error(e.getMessage(), e);
                         log.error(e.getMessage(), e);
                     }
                     }
@@ -295,7 +296,7 @@ public class ContentServiceImpl implements ContentService {
                     XxlJobLogger.log("record = {} error", record);
                     XxlJobLogger.log("record = {} error", record);
                 } finally {
                 } finally {
                     try {
                     try {
-                        TimeUnit.SECONDS.sleep(RECORD_SLEEP);
+                        TimeUnit.SECONDS.sleep(recordSleep);
                     } catch (InterruptedException e) {
                     } catch (InterruptedException e) {
                         log.error(e.getMessage(), e);
                         log.error(e.getMessage(), e);
                     }
                     }
@@ -362,7 +363,7 @@ public class ContentServiceImpl implements ContentService {
                     XxlJobLogger.log("record = {} error", record);
                     XxlJobLogger.log("record = {} error", record);
                 } finally {
                 } finally {
                     try {
                     try {
-                        TimeUnit.SECONDS.sleep(RECORD_SLEEP);
+                        TimeUnit.SECONDS.sleep(recordSleep);
                     } catch (InterruptedException e) {
                     } catch (InterruptedException e) {
                         log.error(e.getMessage(), e);
                         log.error(e.getMessage(), e);
                     }
                     }