lib/logstash/outputs/lumberjack.rb in logstash-output-lumberjack-1.0.3 vs lib/logstash/outputs/lumberjack.rb in logstash-output-lumberjack-2.0.0

- old
+ new

@@ -56,17 +56,14 @@ end # def register public def receive(event) return unless output?(event) - if event == LogStash::SHUTDOWN - finished - return - end # LogStash::SHUTDOWN + return if event == LogStash::SHUTDOWN @codec.encode(event) end # def receive - def flush(events, teardown = false) + def flush(events, close = false) begin @logger.info("Sending events to lumberjack", :size => events.size) @client.write(events) rescue Exception => e @logger.error("Client write error, trying connect", :e => e, :backtrace => e.backtrace)