カスタム再試行ポリシーを使用している再試行テンプレートをテストしようとしています。そのために、次の例を使用しています。
基本的に、私の目標は、特定の http エラー ステータス (http 500 エラー ステータスなど) を取得したときに再試行ロジックをテストすることです。
これは私のjunitのxmlコンテキストです:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:int-http="http://www.springframework.org/schema/integration/http"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/http
http://www.springframework.org/schema/integration/http/spring-integration-http.xsd">
<bean id="retryTemplate_test" class="org.springframework.retry.support.RetryTemplate">
<property name="retryPolicy">
<bean
class="util.CustomRetryPolicy">
<property name="maxAttempts" value="5" />
</bean>
</property>
<property name="backOffPolicy">
<bean class="org.springframework.retry.backoff.ExponentialBackOffPolicy">
<property name="initialInterval" value="1000" />
<property name="multiplier" value="6" />
</bean>
</property>
</bean>
</beans>
どこCustomRetryPolicyに似ています：
public class CustomRetryPolicy extends ExceptionClassifierRetryPolicy {
private String maxAttempts;
@PostConstruct
public void init() {
this.setExceptionClassifier(new Classifier<Throwable, RetryPolicy>() {
@Override
public RetryPolicy classify(Throwable classifiable) {
Throwable exceptionCause = classifiable.getCause();
if (exceptionCause instanceof HttpStatusCodeException) {
int statusCode = ((HttpStatusCodeException) classifiable.getCause()).getStatusCode().value();
return handleHttpErrorCode(statusCode);
}
return neverRetry();
}
});
}
public void setMaxAttempts(String maxAttempts) {
this.maxAttempts = maxAttempts;
}
private RetryPolicy handleHttpErrorCode(int statusCode) {
RetryPolicy retryPolicy = null;
switch(statusCode) {
case 404 :
case 500 :
case 503 :
case 504 :
retryPolicy = defaultRetryPolicy();
break;
default :
retryPolicy = neverRetry();
break;
}
return retryPolicy;
}
private RetryPolicy neverRetry() {
return new NeverRetryPolicy();
}
private RetryPolicy defaultRetryPolicy() {
final SimpleRetryPolicy simpleRetryPolicy = new SimpleRetryPolicy();
simpleRetryPolicy.setMaxAttempts(Integer.valueOf(maxAttempts));
return simpleRetryPolicy;
}
}
そして、私がテストしている Java クラスは次のとおりです。
@RunWith( SpringJUnit4ClassRunner.class )
@ContextConfiguration(locations = {"classpath:my_context_for_test.xml"})
public class RetryTemplateTest{
@Autowired
@Qualifier("retryTemplate_test")
RetryTemplate retryTemplate_test;
@Test
public void testRetry() throws Throwable {
Map<Class<? extends Throwable>, Boolean> r = new HashMap<>();
r.put(HttpStatusCodeException.class, true);
MockRetryCallback callback = new MockRetryCallback();
callback.setAttemptsBeforeSuccess(5);
retryTemplate_test.execute(callback);
assertEquals(5, callback.attempts);
}
private static class MockRetryCallback implements RetryCallback<Object, HttpStatusCodeException> {
private int attempts;
private int attemptsBeforeSuccess;
@SuppressWarnings("serial")
@Override
public Object doWithRetry(RetryContext status) throws HttpStatusCodeException {
this.attempts++;
if (this.attempts < this.attemptsBeforeSuccess) {
System.out.println("I'm here: "+ this.attempts);
throw new HttpStatusCodeException(HttpStatus.INTERNAL_SERVER_ERROR) {
};
}
return null;
}
public void setAttemptsBeforeSuccess(int attemptsBeforeSuccess) {
this.attemptsBeforeSuccess = attemptsBeforeSuccess;
}
}
}
私は何を間違っていますか？私の理解では、コールバックを使用して応答をモックしているので、(カスタムの再試行ポリシーを使用して) その応答を処理できます。また
[アップデート]
この junitを複製しようとすると、同じ例外が発生します。最も具体的には、ここのMockRetryCallbackクラス内で例外をインスタンス化しようとすると失敗します:
private Exception exceptionToThrow = new Exception();