lib/logstash/outputs/lumberjack.rb in logstash-output-lumberjack-3.1.1 vs lib/logstash/outputs/lumberjack.rb in logstash-output-lumberjack-3.1.2
- old
+ new
@@ -59,11 +59,11 @@
@codec.encode(event)
end # def receive
def flush(events, close = false)
begin
- @logger.info("Sending events to lumberjack", :size => events.size)
+ @logger.debug? && @logger.debug("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)
sleep(RECONNECT_BACKOFF_SLEEP)
connect
@@ -76,10 +76,10 @@
end
private
def connect
require 'resolv'
- @logger.info("Connecting to lumberjack server.", :addresses => @hosts, :port => @port,
+ @logger.debug("Connecting to lumberjack server.", :addresses => @hosts, :port => @port,
:ssl_certificate => @ssl_certificate, :flush_size => @flush_size)
begin
ips = []
@hosts.each { |host| ips += Resolv.getaddresses host }
@client = Lumberjack::Client.new(:addresses => ips.uniq, :port => @port,