Contents

module AwsAlertMonitor
  class Parser

    def initialize(args)
      log_level      = args[:log_level]
      @config        = AwsAlertMonitor::Config.new :log_level => log_level
      @config_file   = @config.file
      @logger        = @config.logger
    end

    def run
      @config_file.each_pair do |name, data|
        sqs_endpoint = data['sqs_endpoint']
        access_key   = data['access_key']
        secret_key   = data['secret_key']
        events       = data['events']

        ::AWS.config :access_key_id     => access_key,
                     :secret_access_key => secret_key

        @logger.info "Processing #{name}."
        @logger.debug "Receiving messages from #{sqs_endpoint}"

        count = sqs.approximate_number_of_messages sqs_endpoint
        @logger.info "Approximatley #{count} messages available."

        while message = sqs.receive_message(sqs_endpoint)
          alert.process :name    => name,
                        :message => message.body,
                        :events  => events
          @logger.info "Deleting message from queue."
          message.delete
        end
      end
    end

    private

    def alert
      @alert ||= AwsAlertMonitor::Alert.new :config => @config
    end

    def sqs
      @sqs ||= AwsAlertMonitor::AWS::SQS.new
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
aws-alert-monitor-0.1.0	lib/aws-alert-monitor/parser.rb
aws-alert-monitor-0.0.5	lib/aws-alert-monitor/parser.rb
aws-alert-monitor-0.0.4	lib/aws-alert-monitor/parser.rb
aws-alert-monitor-0.0.3	lib/aws-alert-monitor/parser.rb
aws-alert-monitor-0.0.2	lib/aws-alert-monitor/parser.rb
aws-alert-monitor-0.0.1	lib/aws-alert-monitor/parser.rb