Retrier.java

import com.jasongoodwin.monads.Try;
import org.apache.log4j.Logger;
import java.util.function.Function;

public abstract class Retrier<Tin, Tout> {

    private static Logger logger = Logger.getLogger(WsExecuter.class);

    private int LIMIT_OF_RETRIES;

    protected abstract Function<Tin,Tout> executeRequest();

    public Function<Tin,Tout> execute() {
        return in-> Try.ofFailable(() -> executeRequest().apply(in)).recover(retry(in));
    }

    private Function<Throwable, Tout> retry(Tin in) {
        return throwable -> {
            for (int i = 0; i < LIMIT_OF_RETRIES; i++) {
                Try<Tout> responseTry = Try.ofFailable(()->executeRequest().apply(in))
                        .onFailure(error -> logger.error("Error occurs: " + error.getMessage()));
                if (responseTry.isSuccess()) return responseTry.getUnchecked();
            }
            throw new LimitOfRetriesException();
        };
    }
}

// extends
public class TestRetrier extends Retrier<RequestModel, ResponseModel> {

    public LogonExecuter(TestService testService) {
        this.testService = testService;
    }

    @Override
    protected Function<RequestModel, ResponseModel> executeRequest(){
        return requestModel ->  foo(requestModel);
    }
}

// Use
public class Executer {

    private TestRetrier testRetrier;

    public LogonResponseModel send(RequestModel request){
        return testRetrier.execute().apply(request);
    }
}