public class ThreadPoolSchedulerService extends Object implements GlobalSchedulerService
ThreadPoolSchedulerService| Modifier and Type | Class and Description |
|---|---|
static class |
ThreadPoolSchedulerService.GlobalJDKJobHandle |
| Constructor and Description |
|---|
ThreadPoolSchedulerService(int poolSize) |
| Modifier and Type | Method and Description |
|---|---|
org.drools.core.time.JobHandle |
buildJobHandleForContext(NamedJobContext ctx)
Builds JobHandle based on NamedJobContext
|
void |
initScheduler(org.drools.core.time.TimerService globalTimerService)
Provides handle to inject timerService that owns this scheduler service and initialize it
|
void |
internalSchedule(org.drools.core.time.impl.TimerJobInstance timerJobInstance) |
boolean |
isTransactional()
Indicates if given implementation of scheduler service supports
transactional timer store.
|
boolean |
isValid(GlobalTimerService.GlobalJobHandle jobHandle)
Verifies if given job is still valid or it was already executed/vetoed.
|
boolean |
removeJob(org.drools.core.time.JobHandle jobHandle) |
boolean |
retryEnabled()
Indicates if given implementation of scheduler service supports
retries of failed timer jobs
|
org.drools.core.time.JobHandle |
scheduleJob(org.drools.core.time.Job job,
org.drools.core.time.JobContext ctx,
org.drools.core.time.Trigger trigger) |
void |
setInterceptor(SchedulerServiceInterceptor interceptor)
Allows to set interceptor that will be used to schedule timer instances
|
void |
shutdown()
Allows to shutdown the scheduler service
|
public void initScheduler(org.drools.core.time.TimerService globalTimerService)
GlobalSchedulerServiceinitScheduler in interface GlobalSchedulerServiceglobalTimerService - owner of this scheduler servicepublic void shutdown()
GlobalSchedulerServiceshutdown in interface GlobalSchedulerServicepublic org.drools.core.time.JobHandle scheduleJob(org.drools.core.time.Job job,
org.drools.core.time.JobContext ctx,
org.drools.core.time.Trigger trigger)
scheduleJob in interface org.drools.core.time.SchedulerServicepublic boolean removeJob(org.drools.core.time.JobHandle jobHandle)
removeJob in interface org.drools.core.time.SchedulerServicepublic void internalSchedule(org.drools.core.time.impl.TimerJobInstance timerJobInstance)
internalSchedule in interface org.drools.core.time.InternalSchedulerServicepublic org.drools.core.time.JobHandle buildJobHandleForContext(NamedJobContext ctx)
GlobalSchedulerServicebuildJobHandleForContext in interface GlobalSchedulerServicepublic boolean isTransactional()
GlobalSchedulerServiceisTransactional in interface GlobalSchedulerServicepublic void setInterceptor(SchedulerServiceInterceptor interceptor)
GlobalSchedulerServicesetInterceptor in interface GlobalSchedulerServicepublic boolean retryEnabled()
GlobalSchedulerServiceretryEnabled in interface GlobalSchedulerServicepublic boolean isValid(GlobalTimerService.GlobalJobHandle jobHandle)
GlobalSchedulerServiceisValid in interface GlobalSchedulerServiceCopyright © 2001–2015 JBoss by Red Hat. All rights reserved.