Skip to content

Instantly share code, notes, and snippets.

@dwkoogt
dwkoogt / delay_worker.rb
Created May 17, 2017 19:33
Delay worker with delay handler and Rails adapter for Sneakers
#
# enqueue with following parameters hash:
# - headers
# - work_at - time of execution
# - work_queue - destination queue for actually doing the work
#
class DelayWorker
include Sneakers::Worker
from_queue :treadmill, { handler: Sneakers::Handlers::Delay }