Module: Sad::Worker

Defined in:
lib/sad/worker.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(*args) ⇒ Object 



12
13
14
15
 
# File 'lib/sad/worker.rb', line 12

def enqueue(*args)
	payload = ::Sad::Payload.new(self.to_s, args)
	::Sad::Config.redis.rpush(queue_name, payload.encode)
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.namespace, name].join ':'
end