import org.apache.curator.RetrySleeper; //导入依赖的package包/类
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper)
{
    if ( retryCount < n )
    {
        try
        {
            sleeper.sleepFor(getSleepTimeMs(retryCount, elapsedTimeMs), TimeUnit.MILLISECONDS);
        }
        catch ( InterruptedException e )
        {
            Thread.currentThread().interrupt();
            return false;
        }
        return true;
    }
    return false;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Override
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper) {
  try {
    sleeper.sleepFor(getSleepTimeMs(retryCount), TimeUnit.MILLISECONDS);
  } catch ( InterruptedException e ) {
    Thread.currentThread().interrupt();
    return false;
  }
  return true;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
/**
 * {@inheritDoc}
 * @see org.apache.curator.RetryPolicy#allowRetry(int, long, org.apache.curator.RetrySleeper)
 */
@Override
public boolean allowRetry(final int retryCount, final long elapsedTimeMs, final RetrySleeper sleeper) {
	final int r = retries.incrementAndGet();
	if(elapsedTimeMs < retryPauseTime) {
		try {
			sleeper.sleepFor(retryPauseTime-elapsedTimeMs, TimeUnit.MILLISECONDS);
		} catch (Exception ex) {
			log.warn("RetrySleeper Interrupted", ex);
		}
	}
	log.info("Attempting connect retry #{} to [{}]", r, zookeepConnect);
	return true;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Override
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper) {
    if (elapsedTimeMs >= maxElapsedTimeMs) {
        return false;
    }
    long sleepTimeMs = Math.min(maxElapsedTimeMs - elapsedTimeMs,
            getSleepTimeMs(retryCount, elapsedTimeMs));
    try {
        sleeper.sleepFor(sleepTimeMs, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        return false;
    }
    return true;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Override
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper)
{
    try
    {
        sleeper.sleepFor(retryIntervalMs, TimeUnit.MILLISECONDS);
    }
    catch (InterruptedException e)
    {
        Thread.currentThread().interrupt();
        log.warn("Error occurred while sleeping", e);
        return false;
    }
    return true;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Bean(initMethod="start", destroyMethod="close")
public CuratorFramework curator(TestingServer zookeeper) throws Exception{
    return CuratorFrameworkFactory.newClient(
            zookeeper.getConnectString(),
            5000,
            5000,
            new RetryPolicy() {
	public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper) { return false; }
});
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Override
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper) {
	return false;
}
 

import org.apache.curator.RetrySleeper; //导入依赖的package包/类
@Override
public boolean allowRetry(int retryCount, long elapsedTimeMs, RetrySleeper sleeper)
{
    return super.allowRetry(retryCount, elapsedTimeMs, sleeper) && (elapsedTimeMs < maxElapsedTimeMs);
}