src-java/flowhs-topology/flowhs-storm-topology/src/main/java/org/openkilda/wfm/topology/flowhs/service/FlowDeleteService.java
/**
     * Handles async response from worker.
     *
     * @param key command identifier.
     */
Handles async response from worker.
@param key command identifier.
Handles async response from worker . @param key command identifier .
public void handleAsyncResponse(String key, SpeakerFlowSegmentResponse flowResponse) {
        log.debug("Received flow command response {}", flowResponse);
        FlowDeleteFsm fsm = fsms.get(key);
        if (fsm == null) {
            log.warn("Failed to find a FSM: received response with key {} for non pending FSM", key);
            return;
        }
        FlowDeleteContext context = FlowDeleteContext.builder()
                .speakerFlowResponse(flowResponse)
                .build();
        if (flowResponse instanceof FlowErrorResponse) {
            fsmExecutor.fire(fsm, Event.ERROR_RECEIVED, context);
        } else {
            fsmExecutor.fire(fsm, Event.RESPONSE_RECEIVED, context);
        }
        removeIfFinished(fsm, key);
    }
public void handleAsyncResponse ( String key , SpeakerFlowSegmentResponse flowResponse ) { log . debug ( "Received flow command response {}" , flowResponse ) ; FlowDeleteFsm fsm = fsms . get ( key ) ; if ( fsm == null ) { log . warn ( "Failed to find a FSM: received response with key {} for non pending FSM" , key ) ; return ; } FlowDeleteContext context = FlowDeleteContext . builder ( ) . speakerFlowResponse ( flowResponse ) . build ( ) ; if ( flowResponse instanceof FlowErrorResponse ) { fsmExecutor . fire ( fsm , Event . ERROR_RECEIVED , context ) ; } else { fsmExecutor . fire ( fsm , Event . RESPONSE_RECEIVED , context ) ; } removeIfFinished ( fsm , key ) ; }
Handles async response from worker.
Handles async response from worker .