From 0800b7b5199b9e06282ed3a22b18d0092f018b06 Mon Sep 17 00:00:00 2001 From: Cheng Wang Date: Mon, 24 Apr 2023 10:27:18 -0700 Subject: [PATCH] minor name change --- .../com/netflix/priam/scheduler/PriamScheduler.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 {