main/src/main/java/org/onap/policy/pap/main/comm/msgdata/RequestImpl.java
/**
     * Handles a timeout.
     *
     * @param timerName the timer timer
     */
Handles a timeout.
@param timerName the timer timer
Handles a timeout . @param timerName the timer timer
private void handleTimeout(String timerName) {
        synchronized (params.getModifyLock()) {
            if (!svcmgr.isAlive()) {
                return;
            }
            stopPublishing();
            if (!bumpRetryCount()) {
                logger.info("{} timeout {} - retry count {} exhausted", getName(), timerName, retryCount);
                listener.retryCountExhausted();
                return;
            }
            logger.info("{} timeout - re-publish count {}", getName(), retryCount);
            int count = retryCount;
            startPublishing();
            retryCount = count;
        }
    }
private void handleTimeout ( String timerName ) { synchronized ( params . getModifyLock ( ) ) { if ( ! svcmgr . isAlive ( ) ) { return ; } stopPublishing ( ) ; if ( ! bumpRetryCount ( ) ) { logger . info ( "{} timeout {} - retry count {} exhausted" , getName ( ) , timerName , retryCount ) ; listener . retryCountExhausted ( ) ; return ; } logger . info ( "{} timeout - re-publish count {}" , getName ( ) , retryCount ) ; int count = retryCount ; startPublishing ( ) ; retryCount = count ; } }
Handles a timeout.
Handles a timeout .
// this particular request must have been discarded // re-publish // startPublishing() resets the count, so save & restore it here