Class: RainCatcher::Subscriber

Inherits:
Object
  • Object
show all
Defined in:
lib/rain_catcher/subscriber.rb

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Subscriber

Returns a new instance of Subscriber.



5
6
7
8
9
10
11
 
# File 'lib/rain_catcher/subscriber.rb', line 5

def initialize(options)
  @interval = options.fetch(:interval)
  @log_level = options.fetch(:log_level).to_s.downcase.to_sym
  @application_name = options.fetch(:application_name)
  @environment = options.fetch(:environment)
  @last_logged = nil
end

Instance Method Details

#log_if_interval_elapsed ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'lib/rain_catcher/subscriber.rb', line 13

def log_if_interval_elapsed
  return unless elapsed?

  data = queue_data
  return if data.nil?

  Rails.logger.send(@log_level, data.to_json)
  @last_logged = Time.now.utc
end