Merge pull request #6 from mattibf/issue5_flush_logs_on_close

Avoid data loss in stop Send entries before stop (closes #5 )
logstash-plugins · Nov 20, 2018 · 3ed60dc · 3ed60dc
2 parents f4cda88 + ab9dff4
commit 3ed60dc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/logstash/outputs/monasca_log_api.rb b/lib/logstash/outputs/monasca_log_api.rb
@@ -208,6 +208,10 @@ def start_time_check
   end
 
   def stop_time_check
+    #ensure that entries buffered in queue will be  handled before stop
+    @mutex.synchronize do
+      send_logs
+    end
     @time_thread.kill() if @time_thread
     @logger.info('Stopped time_check thread')
   end