BaseService.java 文件源码

@Async
public void attemptToInitialize() {

    // count the attempt
    setInitAttempts(getInitAttempts() + 1);
    logger.debug("initialization attempt " + getInitAttempts());

    // first - get the service information or register service with metadata
    if(getService() != null) {
        // if we were able to get the service data we're registered
        setRegistered(true);
        // second - invoke any custom initialization method 
        setInitialized(initialize(getServiceId()));
    }

    // if both are successful, then we're done
    if(isRegistered() && isInitialized()) {
        logger.info("initialization successful.");
    } else {
        // otherwise see if we need to keep going
        if((getInitRetries() == 0) || (getInitAttempts() < getInitRetries())) {
            logger.debug("initialization unsuccessful. sleeping " + getInitInterval());
            try {
                Thread.sleep(getInitInterval());
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            // start up the next thread
            attemptToInitialize();

        } else {
            // here, we've failed and run out of retries, so just be done.
            logger.info("initialization unsuccessful after " + getInitAttempts() + " attempts.  Giving up.");
            // TODO: what do we do here? exit?
            Application.exit(-1);
        }
    } 
}