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

- fix amqp input connection retry failure.

Browse source
This commit is contained in:
Jordan Sissel 2011-07-01 17:32:50 -07:00
parent e3a05b9ea6
commit 81cb804104
1 changed files with 2 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
lib/logstash/inputs/amqp.rb
View file

@ -71,10 +71,9 @@ class LogStash::Inputs::Amqp < LogStash::Inputs::Base
end # def register
def run(queue)
@logger.debug("Connecting with AMQP settings #{@amqpsettings.inspect} to set up #{@mqtype.inspect} queue #{@name.inspect}")
@bunny = Bunny.new(@amqpsettings)
begin
@logger.debug("Connecting with AMQP settings #{@amqpsettings.inspect} to set up #{@mqtype.inspect} queue #{@name.inspect}")
@bunny = Bunny.new(@amqpsettings)
return if terminating?
@bunny.start