module Resque::Plugins::Brokered
Public Class Methods
included(klass)
click to toggle source
# File lib/resque/plugins/brokered.rb, line 35 def self.included(klass) klass.instance_eval do alias_method :default_reserve, :reserve alias_method :reserve, :reserve_with_strategy alias_method :default_done_working, :done_working alias_method :done_working, :done_working_release_queue end end
Public Instance Methods
done_working_release_queue()
click to toggle source
# File lib/resque/plugins/brokered.rb, line 29 def done_working_release_queue queue = job['queue'] redis.srem :active_queues, queue default_done_working end
reserve_with_broker()
click to toggle source
# File lib/resque/plugins/brokered.rb, line 15 def reserve_with_broker interval = interval.to_i broker = Broker.new(redis, @queues) begin queue, job = broker.pop rescue ThreadError queue, job = nil end log! "Found job on #{queue}" Resque::Job.new(queue, job) if queue && job end
reserve_with_strategy()
click to toggle source
# File lib/resque/plugins/brokered.rb, line 7 def reserve_with_strategy if @queues.any? {|q| q.include? ":"} reserve_with_broker else default_reserve end end