module Message
Public Instance Methods
job(name=nil, &block)
click to toggle source
# File lib/message.rb, line 16 def job(name=nil, &block) if name Job.new(queue(name), &block) else Job end end
log(level, &block)
click to toggle source
# File lib/message.rb, line 32 def log(level, &block) Message.logger.send(level) { "[Thread-#{Thread.current.object_id}] #{block.call}" } end
logger()
click to toggle source
# File lib/message.rb, line 36 def logger @logger ||= Logger.new(STDOUT) end
logger=(logger)
click to toggle source
# File lib/message.rb, line 40 def logger=(logger) @logger = logger end
queue(name=nil)
click to toggle source
# File lib/message.rb, line 8 def queue(name=nil) if name Q.init(name) else Q end end
reset()
click to toggle source
# File lib/message.rb, line 44 def reset Message.queue.reset Message.job.reset Message.worker.reset end
worker(job=nil)
click to toggle source
# File lib/message.rb, line 24 def worker(job=nil) if job Worker.new(job) else Worker end end