测试

src/main/java/com/zskk/dicom/monitor/schedules/StatRunner.java

@@ -55,14 +55,14 @@ public class StatRunner {
         //老上传
         oldUploadPools = generatePools(oldUploadPools, 2);
        // oldUploadPools.execute(new OldUploadRunner());
-         oldUploadPools.execute(new FileUploadsOss(UploadsQueue.fileQueue));
+        oldUploadPools.execute(new FileUploadsOss(FileUploadsOss.FLAG_UPLOAD));
         //新上传
         currentUploadPools = generatePools(currentUploadPools, 2);
         currentUploadPools.execute(new CurrentUploadRunner());
         //重试上传
         retryUploadPools = generatePools(retryUploadPools, 2);
        // retryUploadPools.execute(new RetryUploadRunner());
-        retryUploadPools.execute(new FileUploadsOss(UploadsQueue.failFileQueue));
+        retryUploadPools.execute(new FileUploadsOss(FileUploadsOss.FLAG_RETRY));
     }
 
     public static ExecutorService generatePools(ExecutorService oldPool, int length) {