module

JoobQ::BaseQueue

BaseQueue remains as the abstract base class

Instance methods

add(job : String)
Source
add!(job : String) : String
Source
add_delayed(job : String, at : Time) : String
Source
apply_concurrency(count : Int32)
Source
job_type
Source
name
Source
pause!
Source
paused?
Source
perform(job : Job) : Nil

Override for explicitly injected execution dependencies; serialized jobs do not carry process-local store handles.

Source
resize(count : Int32)
Source
resume!
Source
running_workers
Source
size
Source
start
Source
status
Source
stop!
Source
throttle_limit
Source
total_workers
Source