class AtomicSidekiq::UnitOfWork

Attributes

acknowledge_op[R]
job[R]
queue[R]
requeue_op[R]

Public Class Methods

new(queue = nil, job = nil, in_flight_keymaker:) click to toggle source
# File lib/atomic_sidekiq/unit_of_work.rb, line 5
def initialize(queue = nil, job = nil, in_flight_keymaker:)
  @queue          = queue
  @job            = job
  @acknowledge_op = AtomicOperation::Acknowledge.new(
    in_flight_keymaker: in_flight_keymaker
  )
  @requeue_op = AtomicOperation::Requeue.new(
    in_flight_keymaker: in_flight_keymaker
  )
end

Public Instance Methods

acknowledge() click to toggle source
# File lib/atomic_sidekiq/unit_of_work.rb, line 16
def acknowledge
  acknowledge_op.perform(job: job)
end
queue_name() click to toggle source
# File lib/atomic_sidekiq/unit_of_work.rb, line 20
def queue_name
  queue.sub(/.*queue:/, "")
end
requeue() click to toggle source
# File lib/atomic_sidekiq/unit_of_work.rb, line 24
def requeue
  requeue_op.perform(queue: "queue:#{queue_name}", job: job)
end