Sha256: c3a7634aa6d7816738da3186f2491649559e5a7fdf718fc64ece02cbb7ccec16

Contents?: true

Size: 456 Bytes

Versions: 2

Compression:

Stored size: 456 Bytes

Contents

# frozen_string_literal: true

module Qyu
  module Workers
    module Concerns
      # Qyu::Concerns::FailureQueue
      module FailureQueue
        # Adds ability to workers enqueue failed task to another queue
        #
        # Qyu::Worker.new do
        #   failure_queue true
        #   # or
        #   failure_queue false
        # end
        #

        def failure_queue(fq)
          @failure_queue = fq
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
qyu-1.0.1 lib/qyu/workers/concerns/failure_queue.rb
qyu-1.0.0 lib/qyu/workers/concerns/failure_queue.rb