问题描述
我有一个使用 RetryTemplate 的类。每当出现连接问题时,都会调用 retryConnection() 中的 RetryTemplate 并尝试再次调用方法 checkUser()。
private List<String> retryConnection() throws Exception {
RetryTemplate retryTemplate = new RetryTemplate();
FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();
fixedBackOffPolicy.setBackOffPeriod(2000l);
retryTemplate.setBackOffPolicy(fixedBackOffPolicy);
final String[][] user = new String[1][1];
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(2);
retryTemplate.setRetryPolicy(retryPolicy);
try {
retryTemplate.execute(new RetryCallback<Object>() {
@Override
public Object doWithRetry(RetryContext retryContext) throws Exception {
if (retryContext.getRetryCount() < 2) { // unexpected disconnection
throw new RuntimeException("retry exception");
}
user[0] = checkUser();
System.out.println("RETRY" + retryContext);
return null;
}
});
} catch (Exception e) {
e.printstacktrace();
}
return Arrays.asList(user[0]);
}
我现在需要创建一个 JUNIT 类来测试这个方法。每当在测试类中检测到异常时,应调用 RetryTemplate,然后调用 checkUser() 方法。不确定如何在测试类中实现这一点。请注意 EasyMock 可用于 JUnit 测试。
我创建了一个测试类,如下所示。不确定方向是否正确。
private List<String> retryConnection() throws Exception {
RetryTemplate mockRetry = EasyMock.createMock(RetryTemplate.class);
RetryCallback callback;
try{
//do something
fail("Expected Exception");
}catch (Exception e){
try {
EasyMock.expect(mockRetry.execute((RetryCallback<Object>) RetryContext::getRetryCount)).andReturn(2);
EasyMock.expect(mockRetry.execute((RetryCallback<Object>) RetryContext::getLastThrowable)).andReturn(Exception.class);
} catch (Exception e) {
e.printstacktrace();
}
}
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)