Class: Logasm::Adapters::RabbitmqAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/logasm/adapters/rabbitmq_adapter.rb

Constant Summary collapse

CONFIGURATION_KEYS = 
[:host, :user, :pass, :port]

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(level, service_name, arguments = {}) ⇒ RabbitmqAdapter

Returns a new instance of RabbitmqAdapter.



17
18
19
20
21
22
23
24
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 17

def initialize(level, service_name, arguments = {})
  config = arguments.select { |key, value| CONFIGURATION_KEYS.include?(key) }
  logger = NullLogger.new
  @queue = arguments.fetch(:queue, 'logstash-queue')
  @level = level
  @service_name = service_name
  @freddy = Freddy.build(logger, config.merge({recover_from_connection_close: true}))
end

Instance Attribute Details

#freddy ⇒ Object (readonly)

Returns the value of attribute freddy.



13
14
15
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 13

def freddy
  @freddy
end

Instance Method Details

#debug? ⇒ Boolean

Returns:

  • (Boolean) 


33
34
35
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 33

def debug?
  meets_threshold?(:debug)
end

#error? ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 45

def error?
  meets_threshold?(:error)
end

#fatal? ⇒ Boolean

Returns:

  • (Boolean) 


49
50
51
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 49

def fatal?
  meets_threshold?(:fatal)
end

#info? ⇒ Boolean

Returns:

  • (Boolean) 


37
38
39
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 37

def info?
  meets_threshold?(:info)
end

#log(level, metadata = {}) ⇒ Object 



26
27
28
29
30
31
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 26

def log(level, metadata = {})
  if meets_threshold?(level)
    message = Utils.build_event(metadata, level, @service_name)
    deliver_message message
  end
end

#warn? ⇒ Boolean

Returns:

  • (Boolean) 


41
42
43
 
# File 'lib/logasm/adapters/rabbitmq_adapter.rb', line 41

def warn?
  meets_threshold?(:warn)
end