@Test(expected = RuntimeException.class) public void testDoRetryWithNoIgnoreException() { when(retryHandler.ignoreException()).thenReturn(false); when(retryTaskMapper.queryNeedRetryTaskList(retryHandler.identity(), retryHandler.maxRetryCount(), retryHandler.initialDelay())).thenReturn(newRetryTaskList()); defaultRetryProcessor.doRetry(); }
@Override public void doRetry() { log.info("开始执行Identity={}的重试，maxRetryCount={}, initialDelay={}", genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); List<RetryTask> tasks = retryTaskMapper.queryNeedRetryTaskList(genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); if (tasks == null) { return; } log.info("Identity={}当前有{}个任务准备重试", genericRetryHandler.identity(), tasks.size()); if (genericRetryHandler.ignoreException()) { tasks.forEach(this::doRetryWithIgnoreException); } else { tasks.forEach(this::doRetry); } }
DefaultRetryProcessor implements RetryProcessor { @Override public void doRetry() { log.info("开始执行Identity={}的重试，maxRetryCount={}, initialDelay={}", genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); List<RetryTask> tasks = retryTaskMapper.queryNeedRetryTaskList(genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); if (tasks == null) { return; } log.info("Identity={}当前有{}个任务准备重试", genericRetryHandler.identity(), tasks.size()); if (genericRetryHandler.ignoreException()) { tasks.forEach(this::doRetryWithIgnoreException); } else { tasks.forEach(this::doRetry); } } }
DefaultRetryProcessor implements RetryProcessor { @Override public void doRetry() { log.info("开始执行Identity={}的重试，maxRetryCount={}, initialDelay={}", genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); List<RetryTask> tasks = retryTaskMapper.queryNeedRetryTaskList(genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); if (tasks == null) { return; } log.info("Identity={}当前有{}个任务准备重试", genericRetryHandler.identity(), tasks.size()); if (genericRetryHandler.ignoreException()) { tasks.forEach(this::doRetryWithIgnoreException); } else { tasks.forEach(this::doRetry); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); }
DefaultRetryProcessor implements RetryProcessor { @Override public void doRetry() { log.info("开始执行Identity={}的重试，maxRetryCount={}, initialDelay={}", genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); List<RetryTask> tasks = retryTaskMapper.queryNeedRetryTaskList(genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); if (tasks == null) { return; } log.info("Identity={}当前有{}个任务准备重试", genericRetryHandler.identity(), tasks.size()); if (genericRetryHandler.ignoreException()) { tasks.forEach(this::doRetryWithIgnoreException); } else { tasks.forEach(this::doRetry); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); @Override void doRetry(); }
DefaultRetryProcessor implements RetryProcessor { @Override public void doRetry() { log.info("开始执行Identity={}的重试，maxRetryCount={}, initialDelay={}", genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); List<RetryTask> tasks = retryTaskMapper.queryNeedRetryTaskList(genericRetryHandler.identity(), genericRetryHandler.maxRetryCount(), genericRetryHandler.initialDelay()); if (tasks == null) { return; } log.info("Identity={}当前有{}个任务准备重试", genericRetryHandler.identity(), tasks.size()); if (genericRetryHandler.ignoreException()) { tasks.forEach(this::doRetryWithIgnoreException); } else { tasks.forEach(this::doRetry); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); @Override void doRetry();  }