lib/earthquake/ext.rb in earthquake-1.0.0 vs lib/earthquake/ext.rb in earthquake-1.0.1

- old
+ new

@@ -3,17 +3,19 @@ protected def reconnect_after timeout @reconnect_callback.call(timeout, @reconnect_retries) if @reconnect_callback if timeout == 0 - reconnect @options[:host], @options[:port] start_tls if @options[:ssl] + reconnect @options[:host], @options[:port] else EM.add_timer(timeout) do - reconnect @options[:host], @options[:port] start_tls if @options[:ssl] + reconnect @options[:host], @options[:port] end end + rescue EventMachine::ConnectionError => e + # ignore end end end class String