class

JoobQ::DelayedJobScheduler

Inherits Reference < Object

Constants

Log = ::Log.for("DELAYED_JOB_SCHEDULER")

Constructors

new(store : Store = RedisStore.instance)
Source

Instance methods

delay(job : Job, delay_time : Time::Span)
Source
start

Start the scheduler to process due delayed jobs

Source
stop

Stop the scheduler and wait for its fiber to exit

Source