Package org.apache.solr.common.cloud
Class ZkCmdExecutor
- java.lang.Object
- 
- org.apache.solr.common.cloud.ZkCmdExecutor
 
- 
 public class ZkCmdExecutor extends Object 
- 
- 
Constructor SummaryConstructors Constructor Description ZkCmdExecutor(int timeoutms)ZkCmdExecutor(int timeoutms, ConnectionManager.IsClosed isClosed)TODO: At this point, this should probably take a SolrZkClient in its constructor.
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetRetryDelay()protected voidretryDelay(int attemptCount)Performs a retry delay if this is not the first attempt<T> TretryOperation(ZkOperation<T> operation)Perform the given operation, retrying if the connection failsvoidsetRetryDelay(long retryDelay)
 
- 
- 
- 
Constructor Detail- 
ZkCmdExecutorpublic ZkCmdExecutor(int timeoutms) 
 - 
ZkCmdExecutorpublic 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- 
getRetryDelaypublic long getRetryDelay() 
 - 
setRetryDelaypublic void setRetryDelay(long retryDelay) 
 - 
retryOperationpublic <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
 
 - 
retryDelayprotected void retryDelay(int attemptCount) throws InterruptedExceptionPerforms a retry delay if this is not the first attempt- Parameters:
- attemptCount- the number of the attempts performed so far
- Throws:
- InterruptedException
 
 
- 
 
-