@BeforeClass
public static void initialize() throws URISyntaxException, FileNotFoundException, IOException {
- //Kornyezeti valtozok betoltese
+ // Kornyezeti valtozok betoltese
Properties properties = new Properties();
URL srcLocation = JobengineIT.class.getProtectionDomain().getCodeSource().getLocation();
URL location = new URL(srcLocation, "../../-configuration/mediacube-dev-user.properties");
properties.load(new FileInputStream(location.toURI().getPath().toString()));
System.getProperties().putAll(properties);
- //Rendszer DB reteg
+ // Rendszer DB reteg
manager = new ItemManager();
manager.connect();
}
try {
runtime = jobEngine.submit("fake.xml", "Fake", parameters);
} catch (JobEngineException e) {
- // TODO Auto-generated catch block
e.printStackTrace();
}
runtime.addEventListener(new IJobStatusChangedListener() {
*/
@Test
public void remote_worker() throws Exception {
- //ez barmi lehet
+ // ez barmi lehet
System.setProperty("jobengine.master.server", "http://localhost:8888");
final ThreadSynchronizer sync = new ThreadSynchronizer();
job.setName("Teszt");
job.setSubmitted(new Timestamp(System.currentTimeMillis()));
job.setTemplate("teszt.xml");
- //itemId
+ // itemId
job.setInputs(new Object[] { 100 });
final Stack<ClusteredJob> jobs = new Stack<>();
};
jobEngine.bindItemManagerService(manager);
jobEngine.addJobChangedEventListener(e -> {
- // if (e.getSignalType().equals(SignalType.UPDATE)) {
- // System.out.println(e.getJob().getProgress());
- // }
+ // if (e.getSignalType().equals(SignalType.UPDATE)) {
+ // System.out.println(e.getJob().getProgress());
+ // }
if (SignalType.CREATE.equals(e.getSignalType()))
System.out.println(e.getSignalType());
sync.resume();
jobEngine.shutdown();
- //assertEquals(JobStatus.FINISHED, runtime.getStatus());
+ // assertEquals(JobStatus.FINISHED, runtime.getStatus());
}
@Test