Allow the SQS input plugin to shut down gracefully when no events hav…

…e arrived in the queue. Fixes logstash-plugins#33
danielpops · Jun 5, 2017 · e4a7628 · e4a7628
1 parent 19cd881
commit e4a7628
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/logstash/inputs/sqs.rb b/lib/logstash/inputs/sqs.rb
@@ -145,6 +145,10 @@ def handle_message(message)
   def run(output_queue)
     @logger.debug("Polling SQS queue", :polling_options => polling_options)
 
+    poller.before_request do |stats|
+        throw :stop_polling if stop?
+    end
+
     run_with_backoff do
       poller.poll(polling_options) do |messages, stats|
         break if stop?