Class: Vx::Lib::Consumer::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/vx/lib/consumer/configuration.rb

Constant Summary collapse

DEBUG = 
'VX_CONSUMER_DEBUG'.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Configuration

Returns a new instance of Configuration.



15
16
17
 
# File 'lib/vx/lib/consumer/configuration.rb', line 15

def initialize
  reset!
end

Instance Attribute Details

#builders ⇒ Object

Returns the value of attribute builders.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def builders
  @builders
end

#content_type ⇒ Object

Returns the value of attribute content_type.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def content_type
  @content_type
end

#debug ⇒ Object

Returns the value of attribute debug.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def debug
  @debug
end

#default_exchange_options ⇒ Object

Returns the value of attribute default_exchange_options.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def default_exchange_options
  @default_exchange_options
end

#default_exchange_type ⇒ Object

Returns the value of attribute default_exchange_type.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def default_exchange_type
  @default_exchange_type
end

#default_publish_options ⇒ Object

Returns the value of attribute default_publish_options.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def default_publish_options
  @default_publish_options
end

#default_queue_options ⇒ Object

Returns the value of attribute default_queue_options.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def default_queue_options
  @default_queue_options
end

#heartbeat ⇒ Object

Returns the value of attribute heartbeat.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def heartbeat
  @heartbeat
end

#logger ⇒ Object

Returns the value of attribute logger.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def logger
  @logger
end

#on_error(&block) ⇒ Object

Returns the value of attribute on_error.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def on_error
  @on_error
end

#pool_timeout ⇒ Object

Returns the value of attribute pool_timeout.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def pool_timeout
  @pool_timeout
end

#prefetch ⇒ Object

Returns the value of attribute prefetch.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def prefetch
  @prefetch
end

#spawn_attempts ⇒ Object

Returns the value of attribute spawn_attempts.



10
11
12
 
# File 'lib/vx/lib/consumer/configuration.rb', line 10

def spawn_attempts
  @spawn_attempts
end

Instance Method Details

#debug? ⇒ Boolean

Returns:

  • (Boolean) 


19
20
21
 
# File 'lib/vx/lib/consumer/configuration.rb', line 19

def debug?
  @debug ||= ENV[DEBUG]
end

#reset! ⇒ Object 



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/lib/consumer/configuration.rb', line 32

def reset!
  @default_exchange_type = :topic
  @pool_timeout          = 0.5
  @heartbeat             = :server

  @spawn_attempts        = 1

  @content_type          = 'application/json'
  @prefetch              = 1

  @on_error              = ->(e, env){ nil }

  @builders = {
    pub: Vx::Lib::Rack::Builder.new,
    sub: Vx::Lib::Rack::Builder.new
  }

  @default_exchange_options = {
    durable:     true,
    auto_delete: false
  }

  @default_queue_options = {
    durable:      true,
    auto_delete:  false,
    exclusive:    false
  }

  @default_publish_options = {
  }
end

#use(target, middleware, *args) ⇒ Object 



23
24
25
 
# File 'lib/vx/lib/consumer/configuration.rb', line 23

def use(target, middleware, *args)
  @builders[target].use middleware, *args
end