module LogstashSQS

Constants

VERSION

Public Instance Methods

run() click to toggle source
# File lib/logstash_sqs.rb, line 16
def run
  EventMachine.run do
    files = SettingsProvider.get_files
    files.each do |params|
      Consumer.new(params['path'], -1, params) if File.file?(params['path'])
    end
  end
end