public class GlobalTimerService extends Object implements org.drools.core.time.TimerService, org.drools.core.time.InternalSchedulerService
| Modifier and Type | Class and Description |
|---|---|
static class |
GlobalTimerService.DisposableCommandService |
static class |
GlobalTimerService.GlobalJobHandle |
| Modifier and Type | Field and Description |
|---|---|
protected org.drools.core.time.impl.TimerJobFactoryManager |
jobFactoryManager |
protected org.kie.api.runtime.manager.RuntimeManager |
manager |
protected GlobalSchedulerService |
schedulerService |
protected ConcurrentSkipListSet<GlobalTimerService.GlobalJobHandle> |
startTimerJobs |
protected ConcurrentHashMap<Long,List<GlobalTimerService.GlobalJobHandle>> |
timerJobsPerSession |
| Constructor and Description |
|---|
GlobalTimerService(org.kie.api.runtime.manager.RuntimeManager manager,
GlobalSchedulerService schedulerService) |
| Modifier and Type | Method and Description |
|---|---|
org.drools.core.time.JobHandle |
buildJobHandleForContext(NamedJobContext ctx) |
void |
clearTimerJobInstances(long id) |
void |
destroy() |
long |
getCurrentTime() |
org.kie.api.runtime.ExecutableRunner |
getRunner(org.drools.core.time.JobContext jobContext) |
protected org.kie.api.runtime.ExecutableRunner |
getRunner(Long processInstanceId,
TimerManager.ProcessJobContext ctx) |
org.kie.internal.runtime.manager.InternalRuntimeManager |
getRuntimeManager() |
org.drools.core.time.impl.TimerJobFactoryManager |
getTimerJobFactoryManager() |
Collection<org.drools.core.time.impl.TimerJobInstance> |
getTimerJobInstances(long id) |
ConcurrentHashMap<Long,List<GlobalTimerService.GlobalJobHandle>> |
getTimerJobsPerSession() |
String |
getTimerServiceId() |
long |
getTimeToNextJob() |
void |
internalSchedule(org.drools.core.time.impl.TimerJobInstance timerJobInstance) |
boolean |
removeJob(org.drools.core.time.JobHandle jobHandle) |
void |
reset() |
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 |
setTimerJobFactoryManager(org.drools.core.time.impl.TimerJobFactoryManager timerJobFactoryManager) |
void |
setTimerServiceId(String timerServiceId) |
void |
shutdown() |
protected org.drools.core.time.impl.TimerJobFactoryManager jobFactoryManager
protected final GlobalSchedulerService schedulerService
protected final org.kie.api.runtime.manager.RuntimeManager manager
protected final ConcurrentHashMap<Long,List<GlobalTimerService.GlobalJobHandle>> timerJobsPerSession
protected final ConcurrentSkipListSet<GlobalTimerService.GlobalJobHandle> startTimerJobs
public GlobalTimerService(org.kie.api.runtime.manager.RuntimeManager manager,
GlobalSchedulerService schedulerService)
public 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 long getCurrentTime()
getCurrentTime in interface org.drools.core.time.TimerServicepublic void reset()
reset in interface org.drools.core.time.TimerServicepublic void shutdown()
shutdown in interface org.drools.core.time.TimerServicepublic void destroy()
public long getTimeToNextJob()
getTimeToNextJob in interface org.drools.core.time.TimerServicepublic Collection<org.drools.core.time.impl.TimerJobInstance> getTimerJobInstances(long id)
getTimerJobInstances in interface org.drools.core.time.TimerServicepublic void clearTimerJobInstances(long id)
public void internalSchedule(org.drools.core.time.impl.TimerJobInstance timerJobInstance)
internalSchedule in interface org.drools.core.time.InternalSchedulerServicepublic void setTimerJobFactoryManager(org.drools.core.time.impl.TimerJobFactoryManager timerJobFactoryManager)
setTimerJobFactoryManager in interface org.drools.core.time.TimerServicepublic org.drools.core.time.impl.TimerJobFactoryManager getTimerJobFactoryManager()
getTimerJobFactoryManager in interface org.drools.core.time.TimerServicepublic org.kie.api.runtime.ExecutableRunner getRunner(org.drools.core.time.JobContext jobContext)
public String getTimerServiceId()
public void setTimerServiceId(String timerServiceId)
public org.drools.core.time.JobHandle buildJobHandleForContext(NamedJobContext ctx)
public org.kie.internal.runtime.manager.InternalRuntimeManager getRuntimeManager()
protected org.kie.api.runtime.ExecutableRunner getRunner(Long processInstanceId, TimerManager.ProcessJobContext ctx)
public ConcurrentHashMap<Long,List<GlobalTimerService.GlobalJobHandle>> getTimerJobsPerSession()
Copyright © 2001–2021 JBoss by Red Hat. All rights reserved.