github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-23 22:27:21 -04:00
Code Issues Projects Releases Packages Wiki Activity

LOGSTASH-1886: intercept exception raised by march_hare

Browse source 
Since ae867bc64, the march_hare version we use raises an error when the
network link is broken while the socket is idle. This case must be
handled by logstash to initiate the reconnection process.
This commit is contained in:
Marc Fournier 2014-08-26 11:59:26 +02:00
parent 637694557c
commit abe6bdbbd8
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
lib/logstash/outputs/rabbitmq/march_hare.rb
View file

@ -44,7 +44,7 @@ class LogStash::Outputs::RabbitMQ
else
@logger.warn("Tried to send a message, but not connected to RabbitMQ.")
end
rescue MarchHare::Exception, com.rabbitmq.client.AlreadyClosedException => e
rescue MarchHare::Exception, IOError, com.rabbitmq.client.AlreadyClosedException => e
@connected.set(false)
n = 10