lib/logstash/inputs/jdbc.rb in logstash-integration-jdbc-5.0.1 vs lib/logstash/inputs/jdbc.rb in logstash-integration-jdbc-5.0.2

@@ -281,9 +281,13 @@
     else
       execute_query(queue)
     end
   end # def run
 
+  def close
+    @scheduler.shutdown if @scheduler
+  end
+
   def stop
     close_jdbc_connection
     @scheduler.shutdown(:wait) if @scheduler
   end