@Override
protected void forwardEntry(final ConnectionEntry entry, final long now) {
final Request<? , ?> request = entry.getRequest();
@Override
protected void forwardEntry(final ConnectionEntry entry, final long now) {
final Request<? , ?> request = entry.getRequest();
cohort.forwardRequest(request, entry.getCallback(), this::sendToSuccessor);
} catch (RequestException e) {
entry.complete(request.toRequestFailure(e));
cohort.forwardRequest(request, entry.getCallback(), this::sendToSuccessor);
} catch (RequestException e) {
entry.complete(request.toRequestFailure(e));