@Test public void testDoRetryWithIgnoreException() { when(retryHandler.ignoreException()).thenReturn(true); when(retryTaskMapper.queryNeedRetryTaskList(retryHandler.identity(), retryHandler.maxRetryCount(), retryHandler.initialDelay())).thenReturn(newRetryTaskList()); defaultRetryProcessor.doRetry(); }
private void doRetryWithIgnoreException(RetryTask retryTask) { log.info("开始重试Identity={}，TaskId={}的任务", retryTask.getIdentity(), retryTask.getTaskId()); retryedRetryHandler.setRetryTask(retryTask); String json = retryTask.getParams(); try { if (StringUtils.isBlank(json)) { retryedRetryHandler.handle(null); } else { retryedRetryHandler.parseArgsAndhandle(json); } } catch (RuntimeException e) { log.error(e.getMessage(), e); } }
DefaultRetryProcessor implements RetryProcessor { private void doRetryWithIgnoreException(RetryTask retryTask) { log.info("开始重试Identity={}，TaskId={}的任务", retryTask.getIdentity(), retryTask.getTaskId()); retryedRetryHandler.setRetryTask(retryTask); String json = retryTask.getParams(); try { if (StringUtils.isBlank(json)) { retryedRetryHandler.handle(null); } else { retryedRetryHandler.parseArgsAndhandle(json); } } catch (RuntimeException e) { log.error(e.getMessage(), e); } } }
DefaultRetryProcessor implements RetryProcessor { private void doRetryWithIgnoreException(RetryTask retryTask) { log.info("开始重试Identity={}，TaskId={}的任务", retryTask.getIdentity(), retryTask.getTaskId()); retryedRetryHandler.setRetryTask(retryTask); String json = retryTask.getParams(); try { if (StringUtils.isBlank(json)) { retryedRetryHandler.handle(null); } else { retryedRetryHandler.parseArgsAndhandle(json); } } catch (RuntimeException e) { log.error(e.getMessage(), e); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); }
DefaultRetryProcessor implements RetryProcessor { private void doRetryWithIgnoreException(RetryTask retryTask) { log.info("开始重试Identity={}，TaskId={}的任务", retryTask.getIdentity(), retryTask.getTaskId()); retryedRetryHandler.setRetryTask(retryTask); String json = retryTask.getParams(); try { if (StringUtils.isBlank(json)) { retryedRetryHandler.handle(null); } else { retryedRetryHandler.parseArgsAndhandle(json); } } catch (RuntimeException e) { log.error(e.getMessage(), e); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); @Override void doRetry(); }
DefaultRetryProcessor implements RetryProcessor { private void doRetryWithIgnoreException(RetryTask retryTask) { log.info("开始重试Identity={}，TaskId={}的任务", retryTask.getIdentity(), retryTask.getTaskId()); retryedRetryHandler.setRetryTask(retryTask); String json = retryTask.getParams(); try { if (StringUtils.isBlank(json)) { retryedRetryHandler.handle(null); } else { retryedRetryHandler.parseArgsAndhandle(json); } } catch (RuntimeException e) { log.error(e.getMessage(), e); } } DefaultRetryProcessor(RetryHandler<Object, Object> retryHandler, RetryTaskMapper retryTaskMapper, RetrySerializer retrySerializer); @Override void doRetry();  }