FailedMsgRetryManagerPerformanceTest.java 文件源码

/**
 * Run a bunch of retries.
 *
 * Disabled for now.
 */
public void runTest() throws InterruptedException {
    // Create instance with default settings
    RetryManager retryManager = new DefaultRetryManager();
    retryManager.open(Maps.newHashMap());

    // Do warm up
    logger.info("WARMING UP");
    doTest2(retryManager);

    // Now start test
    logger.info("STARTING TEST");
    retryManager = new DefaultRetryManager();
    retryManager.open(Maps.newHashMap());
    doTest2(retryManager);
}