git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorSweidan Omar <TFS\sweidan.omar>
Fri, 10 Dec 2021 10:26:45 +0000 (10:26 +0000)
committerSweidan Omar <TFS\sweidan.omar>
Fri, 10 Dec 2021 10:26:45 +0000 (10:26 +0000)
server/user.jobengine.osgi.server/test/user/jobengine/server/IT/AMCTests.java

index 33b20deafdd4a1f4ea634672cc1d32da90486ead..694023d9e4aa78a082f6f5226b8ecc7a6357f925 100644 (file)
@@ -43,7 +43,7 @@ public class AMCTests {
 
        @BeforeClass
        public static void initialize() throws Exception {
-               //Kornyezeti valtozok betoltese
+               // Kornyezeti valtozok betoltese
                Properties properties = new Properties();
                URL srcLocation = AMCTests.class.getProtectionDomain().getCodeSource().getLocation();
                URL location = new URL(srcLocation, "../../-configuration/mediacube-dev-user.properties");
@@ -64,7 +64,7 @@ public class AMCTests {
 
        @Test
        public void testForkValidateAndArchive() throws Exception {
-               //Tesztelni egy helyi FTP-n lehet
+               // Tesztelni egy helyi FTP-n lehet
                Path statusPath = Paths.get(output, ".STATUS");
                Files.createDirectories(statusPath);
 
@@ -122,7 +122,7 @@ public class AMCTests {
 
                FileUtils.deleteDirectory(Paths.get(output).toFile());
                jobEngine.shutdown();
-               //assertEquals(jobRuntime.getStatus())
+               // assertEquals(jobRuntime.getStatus())
 
        }
 
@@ -162,7 +162,6 @@ public class AMCTests {
                                }
                                return super.submit(template, name, parameters);
                        }
-
                };
                jobEngine.startup();
                jobEngine.bindItemManagerService(manager);
@@ -175,8 +174,8 @@ public class AMCTests {
                jobParams.put("limit", 1);
 
                IJobRuntime jobRuntime = jobEngine.submit(null, e -> {
-                       //                      if (e.isRuntimeTerminated())
-                       //                              finishLatch.countDown();
+                       // if (e.isRuntimeTerminated())
+                       // finishLatch.countDown();
                }, "fork-validate-and-restore.xml", "Fork validate and archive", jobParams);
 
                if (jobRuntime != null)
@@ -184,13 +183,13 @@ public class AMCTests {
 
                FileUtils.deleteDirectory(Paths.get(output).toFile());
                jobEngine.shutdown();
-               //assertEquals(jobRuntime.getStatus())
+               // assertEquals(jobRuntime.getStatus())
 
        }
 
        @Test
        public void testGenericArchiveChecker() throws Exception {
-               //Tesztelni egy helyi FTP-n lehet
+               // Tesztelni egy helyi FTP-n lehet
 
                jobEngine = new JobEngine();
                jobEngine.startup();
@@ -232,7 +231,7 @@ public class AMCTests {
 
        @Test
        public void testNexioArchiveChecker() throws Exception {
-               //Tesztelni a HirTV-n lehet
+               // Tesztelni a HirTV-n lehet
 
                jobEngine = new JobEngine();
                jobEngine.startup();
@@ -398,7 +397,8 @@ public class AMCTests {
                        storeUri.modify();
                }
                StoreUri tempUri = manager.ensureUri("LOCAL", output, false, false, RemoteStoreProtocol.LOCAL);
-               StoreUri targetStoreUri = manager.ensureUri("TEST TARGET", output + "/target", false, false, RemoteStoreProtocol.LOCAL);
+               StoreUri targetStoreUri = manager.ensureUri("TEST TARGET", output + "/target", false, false,
+                               RemoteStoreProtocol.LOCAL);
                DownloadableMedia downloadable = new DownloadableMedia();
 
                long frames = 514;
@@ -451,7 +451,8 @@ public class AMCTests {
                        sourceStoreUri.modify();
                }
                StoreUri tempStoreUri = manager.ensureUri("LOCAL", output, false, false, RemoteStoreProtocol.LOCAL);
-               StoreUri targetStoreUri = manager.ensureUri("TEST TARGET", output + "/target", false, false, RemoteStoreProtocol.LOCAL);
+               StoreUri targetStoreUri = manager.ensureUri("TEST TARGET", output + "/target", false, false,
+                               RemoteStoreProtocol.LOCAL);
                DownloadableMedia downloadable = new DownloadableMedia();
 
                long frames = 514;