### Question:
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();  }### Answer:
@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(); }