public class PseudoClockScheduler extends Object implements TimerService, SessionPseudoClock, Externalizable, InternalSchedulerService
Constructor and Description |
---|
PseudoClockScheduler() |
PseudoClockScheduler(InternalWorkingMemory session) |
Modifier and Type | Method and Description |
---|---|
long |
advanceTime(long amount,
TimeUnit unit) |
long |
getCurrentTime()
Returns the current time from the scheduler clock
|
InternalWorkingMemory |
getSession() |
TimerJobFactoryManager |
getTimerJobFactoryManager() |
Collection<TimerJobInstance> |
getTimerJobInstances(long id)
This method may return null for some TimerService implementations that do not want the overhead of maintain this.
|
long |
getTimeToNextJob()
Returns the number of time units (usually ms) to
the next scheduled job
|
void |
internalSchedule(TimerJobInstance timerJobInstance) |
void |
readExternal(ObjectInput in) |
boolean |
removeJob(JobHandle jobHandle)
Remove the job identified by the given job handle from the
scheduled queue
|
void |
reset()
Reset this service
|
JobHandle |
scheduleJob(Job job,
JobContext ctx,
Trigger trigger)
Schedule a job for later execution
|
void |
setSession(InternalWorkingMemory session) |
void |
setStartupTime(long i) |
void |
setTimerJobFactoryManager(TimerJobFactoryManager timerJobFactoryManager) |
void |
shutdown()
Shuts the service down
|
void |
writeExternal(ObjectOutput out) |
public PseudoClockScheduler()
public PseudoClockScheduler(InternalWorkingMemory session)
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void setTimerJobFactoryManager(TimerJobFactoryManager timerJobFactoryManager)
setTimerJobFactoryManager
in interface TimerService
public TimerJobFactoryManager getTimerJobFactoryManager()
getTimerJobFactoryManager
in interface TimerService
public long getCurrentTime()
TimerService
getCurrentTime
in interface TimerService
getCurrentTime
in interface org.kie.api.time.SessionClock
SessionClock.getCurrentTime()
public JobHandle scheduleJob(Job job, JobContext ctx, Trigger trigger)
SchedulerService
scheduleJob
in interface SchedulerService
SchedulerService.scheduleJob(Job, JobContext, Trigger)
public void internalSchedule(TimerJobInstance timerJobInstance)
internalSchedule
in interface InternalSchedulerService
public boolean removeJob(JobHandle jobHandle)
SchedulerService
removeJob
in interface SchedulerService
jobHandle
- the job identity handleSchedulerService.removeJob(JobHandle)
public long advanceTime(long amount, TimeUnit unit)
advanceTime
in interface org.kie.api.time.SessionPseudoClock
public void setStartupTime(long i)
public InternalWorkingMemory getSession()
public void setSession(InternalWorkingMemory session)
session
- the session to setpublic void reset()
TimerService
reset
in interface TimerService
public void shutdown()
TimerService
shutdown
in interface TimerService
public long getTimeToNextJob()
TimerService
getTimeToNextJob
in interface TimerService
public Collection<TimerJobInstance> getTimerJobInstances(long id)
TimerService
getTimerJobInstances
in interface TimerService
Copyright © 2001–2019 JBoss by Red Hat. All rights reserved.