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)