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