IN PROGRESS - issue BATCH-572: Retryable exceptions cannot be skippable
Fix exception message (minor)
This commit is contained in:
@@ -105,7 +105,7 @@ public class RecoveryCallbackRetryPolicy extends AbstractStatefulRetryPolicy {
|
||||
* type.
|
||||
*/
|
||||
public RetryContext open(RetryCallback callback, RetryContext parent) {
|
||||
Assert.state(callback instanceof RecoveryRetryCallback, "Callback must be ItemProviderRetryCallback");
|
||||
Assert.state(callback instanceof RecoveryRetryCallback, "Callback must be RecoveryRetryCallback");
|
||||
ItemWriterRetryContext context = new ItemWriterRetryContext((RecoveryRetryCallback) callback, parent);
|
||||
context.open(callback, null);
|
||||
return context;
|
||||
|
||||
@@ -66,7 +66,7 @@ public class RecoveryRetryPolicyTests extends TestCase {
|
||||
fail("Expected IllegalStateException");
|
||||
}
|
||||
catch (IllegalStateException e) {
|
||||
assertTrue(e.getMessage().indexOf("must be ItemProvider") >= 0);
|
||||
assertTrue(e.getMessage().indexOf("must be RecoveryRetryCallback") >= 0);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user