From e61800d7f5ca7f7463eaf8faae584c4270c4000a Mon Sep 17 00:00:00 2001 From: Sweidan Omar Date: Fri, 10 Dec 2021 10:26:45 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32548 --- .../user/jobengine/server/IT/AMCTests.java | 23 ++++++++++--------- 1 file changed, 12 insertions(+), 11 deletions(-) diff --git a/server/user.jobengine.osgi.server/test/user/jobengine/server/IT/AMCTests.java b/server/user.jobengine.osgi.server/test/user/jobengine/server/IT/AMCTests.java index 33b20dea..694023d9 100644 --- a/server/user.jobengine.osgi.server/test/user/jobengine/server/IT/AMCTests.java +++ b/server/user.jobengine.osgi.server/test/user/jobengine/server/IT/AMCTests.java @@ -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; -- 2.54.0