src-java/flowhs-topology/flowhs-storm-topology/src/main/java/org/openkilda/wfm/topology/flowhs/service/FlowUpdateService.java
/**
     * Handles timeout case.
     *
     * @param key command identifier.
     */
Handles timeout case.
@param key command identifier.
Handles timeout case . @param key command identifier .
public void handleTimeout(String key) {
        log.debug("Handling timeout for {}", key);
        FlowUpdateFsm fsm = fsms.get(key);
        if (fsm == null) {
            log.warn("Failed to find a FSM: timeout event for non pending FSM with key {}", key);
            return;
        }
        fsmExecutor.fire(fsm, Event.TIMEOUT, null);
        removeIfFinished(fsm, key);
    }
public void handleTimeout ( String key ) { log . debug ( "Handling timeout for {}" , key ) ; FlowUpdateFsm fsm = fsms . get ( key ) ; if ( fsm == null ) { log . warn ( "Failed to find a FSM: timeout event for non pending FSM with key {}" , key ) ; return ; } fsmExecutor . fire ( fsm , Event . TIMEOUT , null ) ; removeIfFinished ( fsm , key ) ; }
Handles timeout case.
Handles timeout case .