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 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
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.SchedulerService
public boolean removeJob(org.drools.core.time.JobHandle jobHandle)
removeJob
in interface org.drools.core.time.SchedulerService
public long getCurrentTime()
getCurrentTime
in interface org.drools.core.time.TimerService
public void reset()
reset
in interface org.drools.core.time.TimerService
public void shutdown()
shutdown
in interface org.drools.core.time.TimerService
public void destroy()
public long getTimeToNextJob()
getTimeToNextJob
in interface org.drools.core.time.TimerService
public Collection<org.drools.core.time.impl.TimerJobInstance> getTimerJobInstances(long id)
getTimerJobInstances
in interface org.drools.core.time.TimerService
public void clearTimerJobInstances(long id)
public void internalSchedule(org.drools.core.time.impl.TimerJobInstance timerJobInstance)
internalSchedule
in interface org.drools.core.time.InternalSchedulerService
public void setTimerJobFactoryManager(org.drools.core.time.impl.TimerJobFactoryManager timerJobFactoryManager)
setTimerJobFactoryManager
in interface org.drools.core.time.TimerService
public org.drools.core.time.impl.TimerJobFactoryManager getTimerJobFactoryManager()
getTimerJobFactoryManager
in interface org.drools.core.time.TimerService
public 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–2019 JBoss by Red Hat. All rights reserved.