module Message

# File lib/message.rb, line 16
def job(name=nil, &block)
  if name
    Job.new(queue(name), &block)
  else
    Job
  end
end

# File lib/message.rb, line 32
def log(level, &block)
  Message.logger.send(level) { "[Thread-#{Thread.current.object_id}] #{block.call}" }
end

# File lib/message.rb, line 36
def logger
  @logger ||= Logger.new(STDOUT)
end

# File lib/message.rb, line 40
def logger=(logger)
  @logger = logger
end

# File lib/message.rb, line 8
def queue(name=nil)
  if name
    Q.init(name)
  else
    Q
  end
end

# File lib/message.rb, line 44
def reset
  Message.queue.reset
  Message.job.reset
  Message.worker.reset
end

# File lib/message.rb, line 24
def worker(job=nil)
  if job
    Worker.new(job)
  else
    Worker
  end
end