class

ActiveJob::RedisQueueAdapter

Inherits ActiveJob::Adapter < Reference < Object

Constructors

new(url : String = ENV.fetch("REDIS_URL", "redis:///"))
Source

Instance methods

claim(queues : Array(String), limit : Int32) : Array(Hash(String, ArgValue))

Claims up to limit due jobs from queues, promoting due scheduled jobs first (FIFO by score). Returns job data hashes for Base.deserialize.

Source
claim(queue : String, limit : Int32) : Array(Hash(String, ArgValue))
Source
clear
Source
enqueue(record : EnqueuedJob) : Nil
Source
enqueue_recurring(task_key : String, run_at : Time, record : EnqueuedJob) : Nil
Source
finished(data : Hash(String, ArgValue)) : Nil

No history: performing pops for good. These exist so worker code is adapter-agnostic.

Source
pending_count
Source
perform_one(data : Hash(String, ArgValue)) : Nil
Source
release(data : Hash(String, ArgValue)) : Nil
Source
scheduled_count
Source
work(queues : Array(String) = ["default"], batch : Int32 = 10, poll_interval : Time::Span = 0.01.seconds, stop : Channel(Nil) | Nil = nil) : Nil
Source