Class: Sidekiq::Scheduled::Poller
- Inherits:
-
Object
- Object
- Sidekiq::Scheduled::Poller
- Includes:
- Util
- Defined in:
- lib/sidekiq/scheduled.rb
Overview
The Poller checks Redis every N seconds for jobs in the retry or scheduled set have passed their timestamp and should be enqueued. If so, it just pops the job back onto its original queue so the workers can pick it up like any other job.
Constant Summary collapse
- INITIAL_WAIT =
10
Constants included from Util
Instance Method Summary collapse
- #enqueue ⇒ Object
-
#initialize ⇒ Poller
constructor
A new instance of Poller.
- #start ⇒ Object
-
#terminate ⇒ Object
Shut down this instance, will pause until the thread is dead.
Methods included from Util
#fire_event, #hostname, #identity, #logger, #process_nonce, #redis, #safe_thread, #watchdog
Methods included from ExceptionHandler
Constructor Details
Instance Method Details
#enqueue ⇒ Object
75 76 77 78 79 80 81 82 83 84 |
# File 'lib/sidekiq/scheduled.rb', line 75 def enqueue begin @enq.enqueue_jobs rescue => ex # Most likely a problem with redis networking. # Punt and try again at the next interval logger.error ex. handle_exception(ex) end end |
#start ⇒ Object
63 64 65 66 67 68 69 70 71 72 73 |
# File 'lib/sidekiq/scheduled.rb', line 63 def start @thread ||= safe_thread("scheduler") do initial_wait while !@done enqueue wait end Sidekiq.logger.info("Scheduler exiting...") end end |
#terminate ⇒ Object
Shut down this instance, will pause until the thread is dead.
53 54 55 56 57 58 59 60 61 |
# File 'lib/sidekiq/scheduled.rb', line 53 def terminate @done = true if @thread t = @thread @thread = nil @sleeper << 0 t.value end end |