class Messaging::Configuration

Global configuration for producer and consumer mixins.

Attributes

consume_from[RW]

@!attribute [r] consume_from

@return [Array<String>]
exchange_options[RW]

@!attribute [r] exchange_options

@return [Hash]
heartbeat[RW]

@!attribute [r] heartbeat

@return [Integer]
logger[RW]

@!attribute [r] logger

@return [#info, #debug, #error]
prefetch[RW]

@!attribute [r] prefetch

@return [Integer]
publish_to[RW]

@!attribute [r] publish_to

@return [String]
queue_options[RW]

@!attribute [r] queue_options

@return [Hash]
reconnect_delay[RW]

@!attribute [r] reconnect_delay

@return [Integer]

Public Class Methods

new() click to toggle source

@api private

# File lib/messaging/configuration.rb, line 49
def initialize
  @publish_to       = "amqp://guest:guest@localhost:5672"
  @consume_from     = [publish_to]
  @prefetch         = 1
  @exchange_options = { :auto_delete => false, :durable => true }
  @queue_options    = exchange_options
  @reconnect_delay  = 5
  @heartbeat        = 5
  @logger           = Logger.new(STDOUT)
end
setup() { |instance| ... } click to toggle source

@yieldparam [Messaging::Configuration] config @api public

# File lib/messaging/configuration.rb, line 12
def self.setup(&block)
  yield(Configuration.instance)
end