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