Contents

begin
  require 'freddy'
rescue LoadError => e
  raise unless e.message =~ /freddy/
  exception = e.exception('To use RabbitMQ adapter for logging, please install freddy!')
  exception.set_backtrace(e.backtrace)
  raise exception
end

require_relative 'rabbitmq_adapter/message_builder'

class Logasm
  module Adapters
    class RabbitmqAdapter
      attr_reader :publisher

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

      def initialize(level, service, arguments = {})
        config = arguments.select { |key, value| CONFIGURATION_KEYS.include?(key) }
        logger = Logger.new(STDOUT)
        @queue = arguments.fetch(:queue, 'logstash-queue')
        @level = level

        @message_builder = MessageBuilder.new(service)
        @freddy = Freddy.build(logger, config)
      end

      def log(level, metadata = {})
        if meets_threshold?(level)
          message = @message_builder.build_message metadata, level
          @freddy.deliver @queue, metadata
        end
      end

      private

      def meets_threshold?(level)
        LOG_LEVELS.index(level.to_s) >= @level
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logasm-0.2.0	lib/logasm/adapters/rabbitmq_adapter.rb