lib/redis_failover/client.rb in redis_failover-0.8.4 vs lib/redis_failover/client.rb in redis_failover-0.8.5
- old
+ new
@@ -107,11 +107,10 @@
@db = options[:db]
@retry = options[:retry_failure] || true
@max_retries = @retry ? options.fetch(:max_retries, 3) : 0
@master = nil
@slaves = []
- @queue = Queue.new
@lock = Monitor.new
setup_zk
build_clients
end
@@ -145,10 +144,10 @@
#
# @param [Hash] options the options used for manual failover
# @option options [String] :host the host of the failover candidate
# @option options [String] :port the port of the failover candidate
def manual_failover(options = {})
- ManualFailover.new(zk, options).perform
+ ManualFailover.new(@zk, options).perform
self
end
# Gracefully performs a shutdown of this client. This method is
# mostly useful when the client is used in a forking environment.