Contents

module Sad
	module Worker
		def queue_name
			name = if self.respond_to?(:queue)
				self.send :queue
			else
				nil
			end
			Sad::Config.queue(name)
		end

		def enqueue(*args)
			payload = ::Sad::Payload.new(self.to_s, args)
			payload.sad_args['queue'] = queue_name
			payload.enqueue do |value|
				yield value if block_given?
			end
		end
	end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sad-1.5.14	lib/sad/worker.rb
sad-1.5.13	lib/sad/worker.rb
sad-1.5.12	lib/sad/worker.rb