Strolch
/
strolch
mirror of https://github.com/strolch-li/strolch.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[New] added StrolchJobsHandler.register(StrolchJob) method

This commit is contained in:
Robert von Burg 2018-09-11 12:48:43 +02:00
parent 5736cead97
commit ba13b981c1
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
li.strolch.agent/src/main/java/li/strolch/job/StrolchJobsHandler.java
View File

@ -38,8 +38,7 @@ public class StrolchJobsHandler extends StrolchComponent {
super.initialize(configuration);
}
public StrolchJob registerAndScheduleJob(Class<? extends StrolchJob> strolchJobClass) {
private StrolchJob instantiateStrolchJob(Class<? extends StrolchJob> strolchJobClass) {
StrolchJob strolchJob;
try {
Constructor<? extends StrolchJob> constructor = strolchJobClass.getConstructor(StrolchAgent.class);
@ -47,13 +46,22 @@ public class StrolchJobsHandler extends StrolchComponent {
} catch (Exception e) {
throw new IllegalArgumentException("Failed to instantiate class " + strolchJobClass.getName(), e);
}
return strolchJob;
}
public StrolchJob registerAndScheduleJob(Class<? extends StrolchJob> strolchJobClass) {
return register(instantiateStrolchJob(strolchJobClass)).schedule();
}
public StrolchJob register(Class<? extends StrolchJob> strolchJobClass) {
return register(instantiateStrolchJob(strolchJobClass));
}
public StrolchJob register(StrolchJob strolchJob) {
if (this.jobs.containsKey(strolchJob.getName()))
throw new IllegalArgumentException("Job " + strolchJob.getName() + " is already registered!");
strolchJob.schedule();
this.jobs.put(strolchJob.getName(), strolchJob);
return strolchJob;
}