lib/logstash/inputs/zeromq.rb in logstash-input-zeromq-2.0.2 vs lib/logstash/inputs/zeromq.rb in logstash-input-zeromq-2.0.4

@@ -112,11 +112,15 @@
     end
 
   end # def register
 
   def close
-    error_check(@zsocket.close, "while closing the zmq socket")
-    context.terminate
+    begin
+      error_check(@zsocket.close, "while closing the zmq socket")
+      context.terminate
+    rescue RuntimeError => e
+      @logger.error("Failed to properly teardown ZeroMQ")
+    end
   end # def close
 
   def server?
     @mode == "server"
   end # def server?