I am using @ExponentialRetry on the activity, but it is not retrying the activity. Here is my code in Intellij IDEA.
This is my Activities interface
@ExponentialRetry(
initialRetryIntervalSeconds = 5,
exceptionsToRetry = IllegalStateException.class,
maximumAttempts = 5)
String printHello();
Implementation class:
private boolean check = true; // on the class level
@Override
public String printHello() {
System.out.println("In activity 1111");
if (check) {
check = false;
System.out.println("121212121");
throw new IllegalStateException("showing this for the first time from this activity");
}
return "Hello World";
}
This is my Workflow implementation class from where I am calling this activity through the activities client, means workflow entry point
@Override
public void helloWorld() {
handleUnreliableActivity();
}
private void handleUnreliableActivity() {
new TryCatch() {
@Override
protected void doTry() throws Throwable {
Promise<String> result = client.printHello();
client.printBye(result);
}
@Override
protected void doCatch(Throwable throwable) throws Throwable {
System.out.println("In doCatch **************************");
throw throwable;
}
};
}
Can anyone help?