lib/logstash/inputs/yasuri.rb in logstash-input-yasuri-2.0.6 vs lib/logstash/inputs/yasuri.rb in logstash-input-yasuri-2.0.7

@@ -48,9 +48,11 @@
       # we want to be able to abort the sleep
       # Stud.stoppable_sleep will frequently evaluate the given block
       # and abort the sleep(@interval) if the return value is true
       inner_run(queue)
     end
+
+    @scheduler.join
   end # def run
 
   def stop
     # nothing to do in this case so it is not necessary to define stop
     # examples of common "stop" tasks: