0005399: Adjusted JobManager.loadJobs()

JumpMind · Aug 11, 2022 · bfd8b92 · bfd8b92
1 parent 8f210f9
commit bfd8b92
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/job/JobManager.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/job/JobManager.java
@@ -60,19 +60,19 @@ public JobManager(ISymmetricEngine engine) {
     @Override
     public void init() {
         this.stopJobs();
-        List<JobDefinition> jobDefitions = loadJobs(engine);
+        List<JobDefinition> jobDefinitions = loadCustomJobs();
         BuiltInJobs builtInJobs = new BuiltInJobs();
-        jobDefitions = builtInJobs.syncBuiltInJobs(jobDefitions, engine, taskScheduler); // TODO save built in jobs
+        jobDefinitions = builtInJobs.syncBuiltInJobs(jobDefinitions, engine, taskScheduler); // TODO save built in jobs
         this.jobs = new ArrayList<IJob>();
-        for (JobDefinition jobDefinition : jobDefitions) {
+        for (JobDefinition jobDefinition : jobDefinitions) {
             IJob job = jobCreator.createJob(jobDefinition, engine, taskScheduler);
             if (job != null) {
                 jobs.add(job);
             }
         }
     }
 
-    protected List<JobDefinition> loadJobs(ISymmetricEngine engine) {
+    public List<JobDefinition> loadCustomJobs() {
         return sqlTemplate.query(getSql("loadCustomJobs"), new JobMapper());
     }
 

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/job/IJobManager.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/job/IJobManager.java
@@ -37,6 +37,8 @@ public interface IJobManager {
 
     public void destroy();
 
+    public List<JobDefinition> loadCustomJobs();
+
     public List<IJob> getJobs();
 
     public IJob getJob(String name);