github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

- more detailed logs

Browse source
This commit is contained in:
Jordan Sissel 2011-07-01 17:33:24 -07:00
parent c95912dd8d
commit a64e0bd7c8
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/logstash/outputs/amqp.rb
View file

@ -59,10 +59,10 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
:vhost => @vhost,
:host => @host,
:port => @port
:logging => @debug,
}
amqpsettings[:user] = @user if @user
amqpsettings[:pass] = @password.value if @password
amqpsettings[:logging] = @debug
begin
@logger.debug(["Connecting to AMQP", amqpsettings, @exchange_type, @name])
@ -72,7 +72,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
if terminating?
return
else
@logger.error("AMQP connection error, will reconnect: #{e}")
@logger.error("AMQP connection error (during connect), will reconnect: #{e}")
@logger.debug(["Backtrace", e.backtrace])
sleep(1)
retry
@ -96,7 +96,7 @@ class LogStash::Outputs::Amqp < LogStash::Outputs::Base
@logger.warn("Tried to send message, but not connected to amqp yet.")
end
rescue *[Bunny::ServerDownError, Errno::ECONNRESET] => e
@logger.error("AMQP connection error, will reconnect: #{e}")
@logger.error("AMQP connection error (during publish), will reconnect: #{e}")
connect
retry
end