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