- try {
- final ProxyReconnectCohort cohort = cohorts.get(historyId);
- if (cohort == null) {
- LOG.warn("Cohort for request {} not found, aborting it", request);
- throw new CohortNotFoundException(historyId);
- }
-
- // FIXME: do not use sendRequest() once we have throttling in place, as we have already waited the
- // period required to get into the queue.
- cohort.replayRequest(request, entry.getCallback(), this::sendToSuccessor);
- } catch (RequestException e) {
- entry.complete(request.toRequestFailure(e));
+ final ProxyReconnectCohort cohort = cohorts.get(historyId);
+ if (cohort == null) {
+ LOG.warn("Cohort for request {} not found, aborting it", request);
+ throw new CohortNotFoundException(historyId);