io.zeebe.util.sched

Class TimerSubscription

java.lang.Object

io.zeebe.util.sched.TimerSubscription

All Implemented Interfaces:

ActorSubscription, ScheduledTimer, Runnable

public class TimerSubscription
extends Object
implements ActorSubscription, ScheduledTimer, Runnable

Constructor Summary

Constructors

Constructor and Description
TimerSubscription(ActorJob job, long deadline, TimeUnit timeUnit, boolean isRecurring)

Method Summary

Modifier and Type	Method and Description
void	cancel()
long	getDeadline()
ActorJob	getJob() called by the ActorThread after ActorSubscription.poll() returned true to get the job to be run
long	getTimerId()
TimeUnit	getTimeUnit()
boolean	isRecurring() Returns true in case the subscription is recurring (ie.
void	onJobCompleted() callback received as the job returned by ActorSubscription.getJob() completes execution.
void	onTimerExpired(TimeUnit timeUnit, long now)
boolean	poll() called by the ActorThread to determine whether the subscription has work available.
void	run()
void	setTimerId(long timerId)
void	submit()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.zeebe.util.sched.ActorSubscription

triggersInPhase

Constructor Detail

TimerSubscription

public TimerSubscription(ActorJob job,
                         long deadline,
                         TimeUnit timeUnit,
                         boolean isRecurring)

Method Detail

poll

public boolean poll()

Description copied from interface: ActorSubscription

called by the ActorThread to determine whether the subscription has work available.

Specified by:

poll in interface ActorSubscription

getJob

public ActorJob getJob()

Description copied from interface: ActorSubscription

called by the ActorThread after ActorSubscription.poll() returned true to get the job to be run

Specified by:

getJob in interface ActorSubscription

isRecurring

public boolean isRecurring()

Description copied from interface: ActorSubscription

Returns true in case the subscription is recurring (ie. after the job finished, the subscription is re-created

Specified by:

isRecurring in interface ActorSubscription

onJobCompleted

public void onJobCompleted()

Description copied from interface: ActorSubscription

callback received as the job returned by ActorSubscription.getJob() completes execution.

Specified by:

onJobCompleted in interface ActorSubscription

setTimerId

public void setTimerId(long timerId)

getTimerId

public long getTimerId()

cancel

public void cancel()

Specified by:

cancel in interface ActorSubscription

Specified by:

cancel in interface ScheduledTimer

submit

public void submit()

getDeadline

public long getDeadline()

getTimeUnit

public TimeUnit getTimeUnit()

onTimerExpired

public void onTimerExpired(TimeUnit timeUnit,
                           long now)

run

public void run()

Specified by:

run in interface Runnable