lib/rabbit_wq.rb in rabbit-wq-0.2.0 vs lib/rabbit_wq.rb in rabbit-wq-0.3.0

- old
+ new

@@ -1,37 +1,40 @@ -require "rabbit_wq/version" +require 'ansi' +require 'rabbit_wq/version' module RabbitWQ - APP_ID = "rabbit-wq" - APP_NAME = "Rabbit Work Queue" - DELAY_QUEUE_PREFIX = "work-delay" # TODO: Make this configurable (from ENV, or file?) - DELAY_EXCHANGE_PREFIX = "work-delay" # TODO: Make this configurable (from ENV, or file?) - ERROR_QUEUE = "work-error" - INT = "INT" - QUEUE = "work" # TODO: Make this configurable (from ENV, or file?) + APP_ID = 'rabbit-wq' + APP_NAME = 'Rabbit Work Queue' + INT = 'INT' VERSION_COPYRIGHT = "v#{VERSION} \u00A9#{Time.now.year}" - WORK_EXCHANGE = "work" # TODO: Make this configurable (from ENV, or file?) autoload :Command, 'rabbit_wq/command' autoload :Configuration, 'rabbit_wq/configuration' autoload :Logging, 'rabbit_wq/logging' autoload :Queues, 'rabbit_wq/queues' autoload :MessageHandler, 'rabbit_wq/message_handler' autoload :Server, 'rabbit_wq/server' + autoload :ServerDaemon, 'rabbit_wq/server_daemon' autoload :ServerLogging, 'rabbit_wq/server_logging' autoload :Work, 'rabbit_wq/work' autoload :Worker, 'rabbit_wq/worker' + autoload :WorkLogger, 'rabbit_wq/work_logger' def self.configuration @configuration ||= Configuration.new end + def self.configuration=( configuration ) + @configuration = configuration + end + def self.configure yield( configuration ) if block_given? end class << self - attr_accessor :logger + attr_accessor :logger, + :work_logger end end