Package com.eka.middleware.scheduling

Class ApplicationSchedulerFactory

java.lang.Object

com.eka.middleware.scheduling.ApplicationSchedulerFactory

public class ApplicationSchedulerFactory
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.logging.log4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
ApplicationSchedulerFactory()

Method Summary

Modifier and Type	Method	Description
static void	deleteScheduler(org.quartz.Scheduler scheduler)
List<org.quartz.JobExecutionContext>	getCurrentlyExecutingJobs(DataPipeline dataPipeline)
static org.quartz.JobKey	getKey(org.quartz.JobDetail jobDetail)
static org.quartz.Scheduler	getSchedulerForTenant(String tenantName)
static org.quartz.SchedulerMetaData	getSchedulerMetaData(org.quartz.Scheduler scheduler)
static org.quartz.Scheduler	initScheduler(String configFile, String tenantName)
static boolean	isSchedulerAlive(DataPipeline dataPipeline)
static void	removeJob(org.quartz.JobKey jobKey, org.quartz.Scheduler scheduler)
static <T extends org.quartz.Job> org.quartz.JobKey	scheduleJob(Class<T> jobClass, String identificationName, String identificationGroup, String serviceFqn, String cronExpression, String job_name, DataPipeline dataPipeline)
static void	startJob(org.quartz.JobKey jobKey, org.quartz.Scheduler scheduler)
static void	startScheduler(DataPipeline dataPipeline)
static void	stopScheduler(DataPipeline dataPipeline)
static void	updateScheduler(org.quartz.JobDetail jobDetail, String newCronExpression, org.quartz.Scheduler scheduler)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

public static org.apache.logging.log4j.Logger LOGGER

Constructor Details

ApplicationSchedulerFactory

public ApplicationSchedulerFactory()

Method Details

initScheduler

public static org.quartz.Scheduler initScheduler(String configFile,
 String tenantName)
                                          throws org.quartz.SchedulerException

Parameters:

configFile -

Returns:

Throws:

org.quartz.SchedulerException

getSchedulerForTenant

public static org.quartz.Scheduler getSchedulerForTenant(String tenantName)

startScheduler

public static void startScheduler(DataPipeline dataPipeline)
                           throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

isSchedulerAlive

public static boolean isSchedulerAlive(DataPipeline dataPipeline)
                                throws org.quartz.SchedulerException

Parameters:

dataPipeline -

Returns:

Throws:

org.quartz.SchedulerException

stopScheduler

public static void stopScheduler(DataPipeline dataPipeline)
                          throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

deleteScheduler

public static void deleteScheduler(org.quartz.Scheduler scheduler)
                            throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

getSchedulerMetaData

public static org.quartz.SchedulerMetaData getSchedulerMetaData(org.quartz.Scheduler scheduler)
                                                         throws org.quartz.SchedulerException

Returns:

Throws:

org.quartz.SchedulerException

getCurrentlyExecutingJobs

public List<org.quartz.JobExecutionContext> getCurrentlyExecutingJobs(DataPipeline dataPipeline)
                                                               throws org.quartz.SchedulerException

Returns:

Throws:

org.quartz.SchedulerException

getKey

public static org.quartz.JobKey getKey(org.quartz.JobDetail jobDetail)
                                throws org.quartz.SchedulerException

Parameters:

jobDetail -

Returns:

Throws:

org.quartz.SchedulerException

removeJob

public static void removeJob(org.quartz.JobKey jobKey,
 org.quartz.Scheduler scheduler)
                      throws org.quartz.SchedulerException

Parameters:

jobKey -

scheduler -

Throws:

org.quartz.SchedulerException

startJob

public static void startJob(org.quartz.JobKey jobKey,
 org.quartz.Scheduler scheduler)
                     throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

updateScheduler

public static void updateScheduler(org.quartz.JobDetail jobDetail,
 String newCronExpression,
 org.quartz.Scheduler scheduler)

Parameters:

jobDetail -

newCronExpression -

scheduleJob

public static <T extends org.quartz.Job>
org.quartz.JobKey scheduleJob(Class<T> jobClass,
 String identificationName,
 String identificationGroup,
 String serviceFqn,
 String cronExpression,
 String job_name,
 DataPipeline dataPipeline)
                       throws org.quartz.SchedulerException

Parameters:

jobClass -

identificationName -

identificationGroup -

cronExpression -

Returns:

Throws:

org.quartz.SchedulerException