Class: Chasqui::Config
- Inherits:
-
Struct
- Object
- Struct
- Chasqui::Config
- Defined in:
- lib/chasqui/config.rb
Instance Method Summary collapse
- #broker_poll_interval ⇒ Object
- #channel ⇒ Object
- #inbox_queue ⇒ Object (also: #inbox)
- #logger ⇒ Object
- #logger=(new_logger) ⇒ Object
- #redis ⇒ Object
- #redis=(redis_config) ⇒ Object
Instance Method Details
#broker_poll_interval ⇒ Object
74 75 76 |
# File 'lib/chasqui/config.rb', line 74 def broker_poll_interval self[:broker_poll_interval] ||= Defaults.fetch(:broker_poll_interval) end |
#channel ⇒ Object
23 24 25 |
# File 'lib/chasqui/config.rb', line 23 def channel self[:channel] ||= Defaults.fetch(:publish_channel) end |
#inbox_queue ⇒ Object Also known as: inbox
27 28 29 |
# File 'lib/chasqui/config.rb', line 27 def inbox_queue self[:inbox_queue] ||= Defaults.fetch(:inbox_queue) end |
#logger ⇒ Object
53 54 55 56 57 58 59 |
# File 'lib/chasqui/config.rb', line 53 def logger unless self[:logger] self.logger = STDOUT end self[:logger] end |
#logger=(new_logger) ⇒ Object
61 62 63 64 65 66 67 68 69 70 71 72 |
# File 'lib/chasqui/config.rb', line 61 def logger=(new_logger) lg = if new_logger.respond_to? :info new_logger else Logger.new(new_logger).tap do |lg| lg.level = Logger::INFO end end lg.progname = 'chasqui' self[:logger] = lg end |
#redis ⇒ Object
32 33 34 35 36 37 38 |
# File 'lib/chasqui/config.rb', line 32 def redis unless self[:redis] self.redis = Redis.new end self[:redis] end |
#redis=(redis_config) ⇒ Object
40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/chasqui/config.rb', line 40 def redis=(redis_config) client = case redis_config when Redis redis_config when String Redis.new url: redis_config else Redis.new redis_config end self[:redis] = Redis::Namespace.new(Defaults.fetch(:redis_namespace), redis: client) end |