public void updateFlowConfig ( FlowConfig flowConfig ) throws RemoteInvocationException { LOG . debug ( "updateFlowConfig with groupName " + flowConfig . getId ( ) . getFlowGroup ( ) + " flowName " + flowConfig . getId ( ) . getFlowName ( ) ) ; FlowId flowId = new FlowId ( ) . setFlowGroup ( flowConfig . getId ( ) . getFlowGroup ( ) ) . setFlowName ( flowConfig . getId ( ) . getFlowName ( ) ) ; UpdateRequest < FlowConfig > updateRequest = _flowconfigsRequestBuilders . update ( ) . id ( new ComplexResourceKey <> ( flowId , new EmptyRecord ( ) ) ) . input ( flowConfig ) . build ( ) ; ResponseFuture < EmptyRecord > response = _restClient . get ( ) . sendRequest ( updateRequest ) ; response . getResponse ( ) ; }
Update a flow configuration