Module: Sad::Worker

Defined in:
lib/sad/worker.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(*args) ⇒ Object 



12
13
14
15
16
17
18
19
 
# 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 ⇒ Object 



3
4
5
6
7
8
9
10
 
# 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