module Sad::Worker
Public Instance Methods
enqueue(*args) { |value| ... }
click to toggle source
# File lib/sad/worker.rb, line 12 def enqueue(*args) payload = ::Sad::Payload.new(self.to_s, args) payload.sad_args['queue'] = queue_name payload.redis = self.redis if self.respond_to?(:redis) payload.enqueue do |value| yield value if block_given? end end
queue_name()
click to toggle source
# File lib/sad/worker.rb, line 3 def queue_name name = if self.respond_to?(:queue) self.send :queue else nil end Sad::Config.queue(name) end