diff --git a/priam/src/main/java/com/netflix/priam/scheduler/PriamScheduler.java b/priam/src/main/java/com/netflix/priam/scheduler/PriamScheduler.java index f8165bcb2..ae498e347 100644 --- a/priam/src/main/java/com/netflix/priam/scheduler/PriamScheduler.java +++ b/priam/src/main/java/com/netflix/priam/scheduler/PriamScheduler.java @@ -29,15 +29,15 @@ public class PriamScheduler { private static final Logger logger = LoggerFactory.getLogger(PriamScheduler.class); private final Scheduler scheduler; - private final PriamJobFactory jobProvider; + private final PriamJobFactory jobFactory; private final Sleeper sleeper; @Inject - public PriamScheduler(SchedulerFactory factory, PriamJobFactory jobProvider, Sleeper sleeper) { + public PriamScheduler(SchedulerFactory factory, PriamJobFactory jobFactory, Sleeper sleeper) { try { this.scheduler = factory.getScheduler(); - this.scheduler.setJobFactory(jobProvider); - this.jobProvider = jobProvider; + this.scheduler.setJobFactory(jobFactory); + this.jobFactory = jobFactory; } catch (SchedulerException e) { throw new RuntimeException(e); } @@ -100,7 +100,7 @@ public void addTaskWithDelay( } public void runTaskNow(Class taskclass) throws Exception { - jobProvider.newJob(taskclass).execute(null); + jobFactory.newJob(taskclass).execute(null); } public void deleteTask(String name) throws SchedulerException {