Sha256: 4ad1c816a1a92bca0ab2b8c71db2c0f1552f0fec5dbd74ac7e4a70a50f52c6b8

Contents?: true

Size: 392 Bytes

Versions: 7

Compression:

Stored size: 392 Bytes

Contents

module Resque
  module Integration
    module Extensions
      # Public: extension for proper determine queue
      # when destroy job with priority
      module Job
        def destroy(queue, klass, *args)
          if klass.respond_to?(:priority?) && klass.priority?
            queue = klass.priority_queue(args.last)
          end

          super
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version Path
resque-integration-3.8.2 lib/resque/integration/extensions/job.rb
resque-integration-3.8.1 lib/resque/integration/extensions/job.rb
resque-integration-3.8.0 lib/resque/integration/extensions/job.rb
resque-integration-3.7.1 lib/resque/integration/extensions/job.rb
resque-integration-3.5.1 lib/resque/integration/extensions/job.rb
resque-integration-3.5.0 lib/resque/integration/extensions/job.rb
resque-integration-3.4.1 lib/resque/integration/extensions/job.rb