Module: SidekiqReliableRequeue

Defined in:
lib/sidekiq-reliable-requeue.rb,
lib/sidekiq-reliable-requeue/worker.rb,
lib/sidekiq-reliable-requeue/middleware.rb,
lib/sidekiq-reliable-requeue/redis_connection.rb

Defined Under Namespace

Classes: Middleware, RedisConnection, Worker

Constant Summary collapse

SidekiqReliableStaleJobsKey = 
'sidekiq_tasks_being_performed'

Class Method Summary collapse

Class Method Details

.initialize(requeue_timeout: 20, reliable_requeue: false) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/sidekiq-reliable-requeue.rb', line 14

def self.initialize(requeue_timeout: 20, reliable_requeue: false)
  Sidekiq.default_worker_options = {
      requeue_timeout:  requeue_timeout,
      reliable_requeue: reliable_requeue
  }

  Sidekiq.configure_server do |config|
    config.on(:startup) do
      Worker.requeue_stale_jobs
    end

    config.server_middleware do |chain|
      chain.add Middleware
    end
  end
end