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.redis = self.redis if self.respond_to?(:redis)
			payload.enqueue do |value|
				yield value if block_given?
			end
		end
	end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sad-1.5.18	lib/sad/worker.rb
sad-1.5.17	lib/sad/worker.rb
sad-1.5.16	lib/sad/worker.rb
sad-1.5.15	lib/sad/worker.rb