Package net.datenwerke.scheduler.service.scheduler

Class SchedulerServiceImpl

java.lang.Object

net.datenwerke.scheduler.service.scheduler.SchedulerServiceImpl

All Implemented Interfaces:

SchedulerService

public class SchedulerServiceImpl
extends Object
implements SchedulerService

Constructor Summary

Constructors

Constructor	Description
SchedulerServiceImpl(JobStore defaultStore, <any> schedulerConfig, EventBus eventBus, HookHandlerService hookHandler, <any> injectorProvider, <any> daemonProvider, <any> watchdogProvider, ConfigService configService, <any> securityServiceProvider, <any> authenticatorServiceProvider, ApplicationPropertiesService propertiesService)

Method Summary

Modifier and Type	Method	Description
void	assertJobChangeAllowed(ReportExecuteJob job)
void	assertJobExecutorChangeAllowed(User previousExecutor, User newExecutor)
void	clearErrorState(AbstractJob job)
void	disable()
void	enable()
void	forceRemove(AbstractJob job)
SchedulerDaemon	getDeamon()
AbstractJob	getJobById(Long id)
List<AbstractJob>	getJobsBy(JobFilterConfiguration filterConfig)
JobStore	getJobStore()
List<ReportScheduleJobListInformation>	getOwnReportJobList(Report report)
List<ReportScheduleJobListInformation>	getReportJobList(Report report)
List<ReportScheduleJobListInformation>	getReportJobListFromCurrentUser(Report report)
List<ReportScheduleJobListInformation>	getReportJobListToCurrentUser(Report report)
boolean	isActive()
boolean	isEnabled()
boolean	isOrderdShutdown()
boolean	isShutdown()
boolean	isTerminated()
boolean	isWatchdogActive()
void	merge(AbstractJob job)
void	remove(AbstractJob job)
void	restart()
void	restartWatchdog()
void	schedule(AbstractJob job, AbstractTrigger trigger)
void	schedule(AbstractJob job, AbstractTrigger trigger, AbstractJob previous)
void	shutdown()
List<Runnable>	shutdownNow()
void	shutdownWatchdog()
void	start()
void	startWatchdog()
void	unschedule(AbstractJob job)

Methods inherited from class java.lang.Object

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

Constructor Details

SchedulerServiceImpl

public SchedulerServiceImpl(JobStore defaultStore,
 <any> schedulerConfig,
 EventBus eventBus,
 HookHandlerService hookHandler,
 <any> injectorProvider,
 <any> daemonProvider,
 <any> watchdogProvider,
 ConfigService configService,
 <any> securityServiceProvider,
 <any> authenticatorServiceProvider,
 ApplicationPropertiesService propertiesService)

Method Details

isActive

public boolean isActive()

Specified by:

isActive in interface SchedulerService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface SchedulerService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface SchedulerService

shutdown

public void shutdown()

Specified by:

shutdown in interface SchedulerService

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface SchedulerService

isOrderdShutdown

public boolean isOrderdShutdown()

Specified by:

isOrderdShutdown in interface SchedulerService

restart

public void restart()
             throws SchedulerStartupException

Specified by:

restart in interface SchedulerService

Throws:

SchedulerStartupException

start

public void start()
           throws SchedulerStartupException

Specified by:

start in interface SchedulerService

Throws:

SchedulerStartupException

startWatchdog

public void startWatchdog()

Specified by:

startWatchdog in interface SchedulerService

isWatchdogActive

public boolean isWatchdogActive()

Specified by:

isWatchdogActive in interface SchedulerService

restartWatchdog

public void restartWatchdog()

Specified by:

restartWatchdog in interface SchedulerService

shutdownWatchdog

public void shutdownWatchdog()

Specified by:

shutdownWatchdog in interface SchedulerService

getJobStore

public JobStore getJobStore()

Specified by:

getJobStore in interface SchedulerService

schedule

public void schedule(AbstractJob job,
 AbstractTrigger trigger)

Specified by:

schedule in interface SchedulerService

schedule

public void schedule(AbstractJob job,
 AbstractTrigger trigger,
 AbstractJob previous)

Specified by:

schedule in interface SchedulerService

unschedule

public void unschedule(AbstractJob job)

Specified by:

unschedule in interface SchedulerService

clearErrorState

public void clearErrorState(AbstractJob job)

Specified by:

clearErrorState in interface SchedulerService

remove

public void remove(AbstractJob job)

Specified by:

remove in interface SchedulerService

forceRemove

public void forceRemove(AbstractJob job)

Specified by:

forceRemove in interface SchedulerService

getJobById

public AbstractJob getJobById(Long id)

Specified by:

getJobById in interface SchedulerService

merge

public void merge(AbstractJob job)

Specified by:

merge in interface SchedulerService

getDeamon

public SchedulerDaemon getDeamon()

Specified by:

getDeamon in interface SchedulerService

getJobsBy

public List<AbstractJob> getJobsBy(JobFilterConfiguration filterConfig)

Specified by:

getJobsBy in interface SchedulerService

enable

public void enable()

Specified by:

enable in interface SchedulerService

disable

public void disable()

Specified by:

disable in interface SchedulerService

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface SchedulerService

getReportJobList

public List<ReportScheduleJobListInformation> getReportJobList(Report report)

Specified by:

getReportJobList in interface SchedulerService

getOwnReportJobList

public List<ReportScheduleJobListInformation> getOwnReportJobList(Report report)

Specified by:

getOwnReportJobList in interface SchedulerService

getReportJobListFromCurrentUser

public List<ReportScheduleJobListInformation> getReportJobListFromCurrentUser(Report report)

Specified by:

getReportJobListFromCurrentUser in interface SchedulerService

getReportJobListToCurrentUser

public List<ReportScheduleJobListInformation> getReportJobListToCurrentUser(Report report)

Specified by:

getReportJobListToCurrentUser in interface SchedulerService

assertJobExecutorChangeAllowed

public void assertJobExecutorChangeAllowed(User previousExecutor,
 User newExecutor)
                                    throws ViolatedSecurityException

Specified by:

assertJobExecutorChangeAllowed in interface SchedulerService

Throws:

ViolatedSecurityException

assertJobChangeAllowed

public void assertJobChangeAllowed(ReportExecuteJob job)
                            throws ViolatedSecurityException

Specified by:

assertJobChangeAllowed in interface SchedulerService

Throws:

ViolatedSecurityException