Module: LogstashSQS

Defined in:
lib/logstash_sqs.rb,
lib/logstash_sqs/version.rb

Constant Summary collapse

VERSION = 
"0.0.6"

Instance Method Summary collapse

Instance Method Details

#run ⇒ Object 



16
17
18
19
20
21
22
23
 
# 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