Class ZkCmdExecutor


  • public class ZkCmdExecutor
    extends Object
    • Constructor Detail

      • ZkCmdExecutor

        public ZkCmdExecutor​(int timeoutms)
      • ZkCmdExecutor

        public ZkCmdExecutor​(int timeoutms,
                             ConnectionManager.IsClosed isClosed)
        TODO: At this point, this should probably take a SolrZkClient in its constructor.
        Parameters:
        timeoutms - the client timeout for the ZooKeeper clients that will be used with this class.
    • Method Detail

      • getRetryDelay

        public long getRetryDelay()
      • setRetryDelay

        public void setRetryDelay​(long retryDelay)
      • retryOperation

        public <T> T retryOperation​(ZkOperation<T> operation)
                             throws org.apache.zookeeper.KeeperException,
                                    InterruptedException
        Perform the given operation, retrying if the connection fails
        Throws:
        org.apache.zookeeper.KeeperException
        InterruptedException
      • retryDelay

        protected void retryDelay​(int attemptCount)
                           throws InterruptedException
        Performs a retry delay if this is not the first attempt
        Parameters:
        attemptCount - the number of the attempts performed so far
        Throws:
        InterruptedException