Backoff and retry for parallel api calls

I have a list of objects that i make parallel api calls and store the result in database. But the problem I am having now is the api goes down and subsequent calls fails I am not sure how I should implement backoff and retry since these are parallel calls I have already executed those
@Async
public CompletableFuture<String> apiCall(String payload){
... resttemplate
return CompletableFuture.completedFuture(..);
}

// Calling class

public List<String> getResponses(List<String> payloads){
List<CompletableFuture<String>> futures = new ArrayList<>();
for(String payload : payloads){
futures.add(apiService.apiCall(payload));
}

return futures.stream()
.map(CompletableFuture::join)
.toList();
}
@Async
public CompletableFuture<String> apiCall(String payload){
... resttemplate
return CompletableFuture.completedFuture(..);
}

// Calling class

public List<String> getResponses(List<String> payloads){
List<CompletableFuture<String>> futures = new ArrayList<>();
for(String payload : payloads){
futures.add(apiService.apiCall(payload));
}

return futures.stream()
.map(CompletableFuture::join)
.toList();
}
1 Reply
JavaBot
JavaBot4w ago
This post has been reserved for your question.
Hey @straightface! Please use /close or the Close Post button above when your problem is solved. Please remember to follow the help guidelines. This post will be automatically marked as dormant after 300 minutes of inactivity.
TIP: Narrow down your issue to simple and precise questions to maximize the chance that others will reply in here. 💤 Post marked as dormant
This post has been inactive for over 300 minutes, thus, it has been archived. If your question was not answered yet, feel free to re-open this post or create a new one. In case your post is not getting any attention, you can try to use /help ping. Warning: abusing this will result in moderative actions taken against you.

Did you find this page helpful?