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