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