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.