class AtomicSidekiq::AtomicOperation::Requeue

Public Instance Methods

perform(queue:, job:) click to toggle source
# File lib/atomic_sidekiq/atomic_operation/requeue.rb, line 4
def perform(queue:, job:)
  redis do |conn|
    requeue(conn, queue: queue, job: job)
  end
end

Private Instance Methods

requeue(conn, queue:, job:) click to toggle source
# File lib/atomic_sidekiq/atomic_operation/requeue.rb, line 12
def requeue(conn, queue:, job:)
  conn.multi do
    conn.rpush(queue, job)
    conn.del(in_flight_keymaker.job_key(job))
  end
end