Contents

module AtomicSidekiq
  module AtomicOperation
    class Requeue < Base
      def perform(queue:, job:)
        redis do |conn|
          requeue(conn, queue: queue, job: job)
        end
      end

      private

      def requeue(conn, queue:, job:)
        conn.multi do
          conn.rpush(queue, job)
          conn.del(in_flight_keymaker.job_key(job))
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
atomic-sidekiq-1.3.0	lib/atomic_sidekiq/atomic_operation/requeue.rb
atomic-sidekiq-1.2.0	lib/atomic_sidekiq/atomic_operation/requeue.rb
atomic-sidekiq-1.1.4	lib/atomic_sidekiq/atomic_operation/requeue.rb
atomic-sidekiq-1.1.3	lib/atomic_sidekiq/atomic_operation/requeue.rb
atomic-sidekiq-1.1.2	lib/atomic_sidekiq/atomic_operation/requeue.rb
atomic-sidekiq-1.1.0	lib/atomic_sidekiq/atomic_operation/requeue.rb