src-java/flowhs-topology/flowhs-storm-topology/src/main/java/org/openkilda/wfm/topology/flowhs/service/FlowUpdateService.java
/**
     * Handles delete flow loop request.
     *
     * @param request request to handle.
     */
Handles delete flow loop request.
@param request request to handle.
Handles delete flow loop request . @param request request to handle .
public void handleDeleteFlowLoopRequest(String key, CommandContext commandContext,
                                            DeleteFlowLoopRequest request) {
        Optional<Flow> flow = flowRepository.findById(request.getFlowId());
        if (flow.isPresent()) {
            FlowRequest flowRequest = RequestedFlowMapper.INSTANCE.toFlowRequest(flow.get());
            flowRequest.setLoopSwitchId(null);
            handleRequest(key, commandContext, flowRequest);
        } else {
            carrier.sendNorthboundResponse(buildFlowNotFoundErrorMessage(request.getFlowId(), commandContext));
        }
    }
public void handleDeleteFlowLoopRequest ( String key , CommandContext commandContext , DeleteFlowLoopRequest request ) { Optional < Flow > flow = flowRepository . findById ( request . getFlowId ( ) ) ; if ( flow . isPresent ( ) ) { FlowRequest flowRequest = RequestedFlowMapper . INSTANCE . toFlowRequest ( flow . get ( ) ) ; flowRequest . setLoopSwitchId ( null ) ; handleRequest ( key , commandContext , flowRequest ) ; } else { carrier . sendNorthboundResponse ( buildFlowNotFoundErrorMessage ( request . getFlowId ( ) , commandContext ) ) ; } }
Handles delete flow loop request.
Handles delete flow loop request .