lib/logstash/inputs/yasuri.rb in logstash-input-yasuri-5.0.5 vs lib/logstash/inputs/yasuri.rb in logstash-input-yasuri-5.0.6

@@ -41,10 +41,10 @@
     @tree  = Yasuri.json2tree(tree)
   end # def register
 
   def run(queue)
     # we can abort the loop if stop? becomes true
-    scheduler.cron @cron do
+    @scheduler.cron @cron do
       # because the sleep interval can be big, when shutdown happens
       # 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)