@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");
@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);
FileUtils.deleteDirectory(Paths.get(output).toFile());
jobEngine.shutdown();
- //assertEquals(jobRuntime.getStatus())
+ // assertEquals(jobRuntime.getStatus())
}
}
return super.submit(template, name, parameters);
}
-
};
jobEngine.startup();
jobEngine.bindItemManagerService(manager);
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)
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();
@Test
public void testNexioArchiveChecker() throws Exception {
- //Tesztelni a HirTV-n lehet
+ // Tesztelni a HirTV-n lehet
jobEngine = new JobEngine();
jobEngine.startup();
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;
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;