Contents

require "sneakers/version"
require 'thread/pool'
require 'bunny'


module Sneakers
  module Handlers
  end
  module Concerns
  end
end

require 'sneakers/support/production_formatter'
require 'sneakers/concerns/logging'
require 'sneakers/concerns/metrics'
require 'sneakers/handlers/oneshot'
require 'sneakers/worker'
require 'sneakers/publisher'

module Sneakers

  Config = {
    # runner
    :runner_config_file => nil,
    :metrics => nil,
    :daemonize => true,
    :start_worker_delay => 0.2,
    :workers => 4,
    :log  => 'sneakers.log',
    :pid_path => 'sneakers.pid',
    :amqp => 'amqp://guest:guest@localhost:55672',

    #workers
    :timeout_job_after => 5,
    :prefetch => 10,
    :threads => 10,
    :env => ENV['RACK_ENV'],
    :durable => true,
    :ack => true,
    :heartbeat_interval => 2,
    :exchange => 'sneakers',
    :hooks => {}
  }

  def self.configure(opts={})
    # worker > userland > defaults
    Config.merge!(opts)

    setup_general_logger!
    setup_worker_concerns!
    setup_general_publisher!
    @configured = true
  end

  def self.logger
    @logger
  end

  def self.publish(msg, routing)
    @publisher.publish(msg, routing)
  end

  def self.configured?
    @configured
  end


private

  def self.setup_general_logger!
    @logger = Logger.new(Config[:log])
    @logger.formatter = Sneakers::Support::ProductionFormatter
  end

  def self.setup_worker_concerns!
    Worker.configure_logger(Sneakers::logger)
    Worker.configure_metrics(Config[:metrics])
    Config[:handler] ||= Sneakers::Handlers::Oneshot
  end

  def self.setup_general_publisher!
    @publisher = Sneakers::Publisher.new
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
sneakers-0.0.5	lib/sneakers.rb
sneakers-0.0.4	lib/sneakers.rb
sneakers-0.0.3	lib/sneakers.rb