lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-2.0.2 vs lib/logstash/outputs/zeromq.rb in logstash-output-zeromq-2.0.4
- old
+ new
@@ -95,10 +95,14 @@
@codec.on_event(&method(:publish))
end # def register
public
def close
- error_check(@zsocket.close, "while closing the socket")
+ begin
+ error_check(@zsocket.close, "while closing the socket")
+ rescue RuntimeError => e
+ @logger.error("Failed to properly teardown ZeroMQ")
+ end
end # def close
private
def server?
@mode == "server"