Sha256: e98259e121f6907635dceebb382c89718df9166b0b99968fab0d5f188dba30fc

Contents?: true

Size: 646 Bytes

Versions: 3

Compression:

Stored size: 646 Bytes

Contents

# -*- encoding : utf-8 -*-
require 'configurable'
require 'logger'

module Untied
  module Publisher
    def self.configure(&block)
      yield(config) if block_given?
      if config.deliver_messages
        Untied::Publisher.start
        EventMachine.next_tick do
          config.channel ||= AMQP::Channel.new(AMQP.connection)
        end
      end
    end

    def self.config
      @config ||= Config.new
    end

    class Config
      include Configurable

      config :logger, Logger.new(STDOUT)
      config :deliver_messages, true
      config :service_name
      config :doorkeeper, nil
      config :channel, nil
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
untied-publisher-0.0.5 lib/untied-publisher/config.rb
untied-publisher-0.0.4 lib/untied-publisher/config.rb
untied-publisher-0.0.3 lib/untied-publisher/config.rb