class

JoobQ::ExpiredJobReaper

Inherits Reference < Object

Constants

DEAD_LETTER = "joobq:dead_letter"
Log = ::Log.for("EXPIRED_JOB_REAPER")
PAGE_SIZE = 100

Constructors

new(store : Store = RedisStore.instance, interval : Time::Span = 30.seconds, scan_limit : Int32 = 1000)
Source

Instance methods

reap_once

Public method for testability — runs a single reap cycle

Source
start
Source
stop
Source