Class: Vx::Common::AMQP::Config
- Inherits:
-
Object
- Object
- Vx::Common::AMQP::Config
- Defined in:
- lib/vx/common/amqp/config.rb
Instance Attribute Summary collapse
-
#content_type ⇒ Object
Returns the value of attribute content_type.
-
#debug ⇒ Object
Returns the value of attribute debug.
-
#default_exchange_options ⇒ Object
Returns the value of attribute default_exchange_options.
-
#default_exchange_type ⇒ Object
Returns the value of attribute default_exchange_type.
-
#default_publish_options ⇒ Object
Returns the value of attribute default_publish_options.
-
#default_queue_options ⇒ Object
Returns the value of attribute default_queue_options.
-
#heartbeat ⇒ Object
Returns the value of attribute heartbeat.
-
#instrumenter ⇒ Object
Returns the value of attribute instrumenter.
-
#logger ⇒ Object
Returns the value of attribute logger.
-
#pool_timeout ⇒ Object
Returns the value of attribute pool_timeout.
-
#spawn_attempts ⇒ Object
Returns the value of attribute spawn_attempts.
-
#url ⇒ Object
Returns the value of attribute url.
Instance Method Summary collapse
- #debug? ⇒ Boolean
- #default_exchange_name ⇒ Object
- #formatter ⇒ Object
-
#initialize ⇒ Config
constructor
A new instance of Config.
- #reset! ⇒ Object
Constructor Details
#initialize ⇒ Config
Returns a new instance of Config.
13 14 15 |
# File 'lib/vx/common/amqp/config.rb', line 13 def initialize reset! end |
Instance Attribute Details
#content_type ⇒ Object
Returns the value of attribute content_type.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def content_type @content_type end |
#debug ⇒ Object
Returns the value of attribute debug.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def debug @debug end |
#default_exchange_options ⇒ Object
Returns the value of attribute default_exchange_options.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def @default_exchange_options end |
#default_exchange_type ⇒ Object
Returns the value of attribute default_exchange_type.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def default_exchange_type @default_exchange_type end |
#default_publish_options ⇒ Object
Returns the value of attribute default_publish_options.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def @default_publish_options end |
#default_queue_options ⇒ Object
Returns the value of attribute default_queue_options.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def @default_queue_options end |
#heartbeat ⇒ Object
Returns the value of attribute heartbeat.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def heartbeat @heartbeat end |
#instrumenter ⇒ Object
Returns the value of attribute instrumenter.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def instrumenter @instrumenter end |
#logger ⇒ Object
Returns the value of attribute logger.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def logger @logger end |
#pool_timeout ⇒ Object
Returns the value of attribute pool_timeout.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def pool_timeout @pool_timeout end |
#spawn_attempts ⇒ Object
Returns the value of attribute spawn_attempts.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def spawn_attempts @spawn_attempts end |
#url ⇒ Object
Returns the value of attribute url.
9 10 11 |
# File 'lib/vx/common/amqp/config.rb', line 9 def url @url end |
Instance Method Details
#debug? ⇒ Boolean
25 26 27 |
# File 'lib/vx/common/amqp/config.rb', line 25 def debug? @debug || ENV['VX_COMMON_AMQP_DEBUG'] end |
#default_exchange_name ⇒ Object
21 22 23 |
# File 'lib/vx/common/amqp/config.rb', line 21 def default_exchange_name "amq.#{default_exchange_type}" end |
#formatter ⇒ Object
17 18 19 |
# File 'lib/vx/common/amqp/config.rb', line 17 def formatter Common::AMQP::Formatter end |
#reset! ⇒ Object
29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/vx/common/amqp/config.rb', line 29 def reset! @url = nil @logger = ::Logger.new(STDOUT) @default_exchange_type = :topic @pool_timeout = 0.1 @heartbeat = 10 @publishing_builder = nil @recieving_builder = nil @subscribing_builder = nil @spawn_attempts = 5 @content_type = 'application/json' @callbacks = {} @instrumenter = nil @default_exchange_options = { durable: true, auto_delete: false } @default_queue_options = { durable: true, autodelete: false, exclusive: false } @default_publish_options = { durable: false } end |