Skip to content

Commit

Permalink
minor name change (#1051)
Browse files Browse the repository at this point in the history
  • Loading branch information
chengw-netflix committed Apr 24, 2023
1 parent b0b5a43 commit 0829ef6
Showing 1 changed file with 5 additions and 5 deletions.
Expand Up @@ -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);
}
Expand Down Expand Up @@ -100,7 +100,7 @@ public void addTaskWithDelay(
}

public void runTaskNow(Class<? extends Task> taskclass) throws Exception {
jobProvider.newJob(taskclass).execute(null);
jobFactory.newJob(taskclass).execute(null);
}

public void deleteTask(String name) throws SchedulerException {
Expand Down

0 comments on commit 0829ef6

Please sign in to comment.