RabbitMQ input plugin failures leave open sockets


Configure a logstash server with the following RabbitMQ input:

The RabbitMQ server should be running, but with nothing putting data into the server. Then wait 15 minutes and see lots of sockets open and messages in the log file of the following form:

The problem is that the code did connect to the server, but did not close the socket.

The error seems to be present even in the latest version, around https://github.com/logstash/logstash/blob/master/lib/logstash/inputs/rabbitmq/march_hare.rb#L52

I think teardown needs to be called in the rescue clause.
But since this looks like a Hot Bunnies issue, I'll cross file there as well, when I find it.


Suyog Rao


Luis F. Ortiz


Affects versions