This version of SDNCAdapterRest allows for interim notifications to be sent for any non-final response received from SDNC.
SequenceFlow_3
SequenceFlow_14
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
def statusCode = execution.getVariable('SDNCREST_sdncAdapterStatusCode')
String response = String.valueOf(execution.getVariable('SDNCREST_sdncAdapterResponse'))
def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
def processKey = sdncAdapterRestV2.getProcessKey(execution)
sdncAdapterRestV2.getLogger().debug("{} received response from SDNCAdapter: statusCode= {} response={}", processKey, statusCode, (response.isEmpty() ? "" : "\n" + response))
SequenceFlow_17
SequenceFlow_35
import org.onap.so.bpmn.common.scripts.*
def exceptionUtil = new ExceptionUtil()
exceptionUtil.buildWorkflowException(execution, 5300, "Failed to communicate with SDNCAdapter")
SequenceFlow_23
SequenceFlow_36
import org.onap.so.bpmn.common.scripts.*
String res = execution.getVariable('SDNCREST_sdncAdapterResponse')
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.sdncAdapterBuildWorkflowException(execution, res)
SequenceFlow_14
SequenceFlow_17
SequenceFlow_23
SequenceFlow_24
#{execution.getVariable("SDNCREST_sdncAdapterStatusCode") == '404'}
#{execution.getVariable("SDNCREST_sdncAdapterStatusCode") == '200' || execution.getVariable("SDNCREST_sdncAdapterStatusCode") == '202'}
SequenceFlow_35
SequenceFlow_36
SequenceFlow_2
SequenceFlow_3
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.sendRequestToSDNCAdapter(execution)
SequenceFlow_9
SequenceFlow_2
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.preProcessRequest(execution)
SequenceFlow_9
SequenceFlow_27
SequenceFlow_34
import org.onap.so.bpmn.common.scripts.*
def exceptionUtil = new ExceptionUtil()
exceptionUtil.buildWorkflowException(execution, 5320, "SDNCAdapter Callback Timeout Error")
SequenceFlow_34
SequenceFlow_44
SequenceFlow_1
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.setSuccessIndicator(execution, true)
execution.setVariable('WorkflowResponse', sdncAdapterRestV2.getLastCallback(execution))
SequenceFlow_1
SequenceFlow_27
${SDNCREST_timeout}
SequenceFlow_24
SequenceFlow_44
SequenceFlow_41
SequenceFlow_42
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.processCallback(execution)
SequenceFlow_25
SequenceFlow_30
SequenceFlow_39
SequenceFlow_43
#{execution.getVariable('SDNCREST_ackFinalIndicator')=="Y"}
SequenceFlow_42
SequenceFlow_8
SequenceFlow_30
#{execution.getVariable("WorkflowException") != null}
SequenceFlow_25
SequenceFlow_0u48ihb
SequenceFlow_0vluoaq
SequenceFlow_41
SequenceFlow_39
SequenceFlow_8
SequenceFlow_43
SequenceFlow_0u48ihb
SequenceFlow_1g8pswz
SequenceFlow_1g8pswz
SequenceFlow_0my3p6y
import org.onap.so.bpmn.common.scripts.*
def sdncAdapterRestV2 = new SDNCAdapterRestV2()
sdncAdapterRestV2.prepareInterimNotification(execution)
#{execution.getVariable("SDNCREST_doInterimNotification") != null && execution.getVariable("SDNCREST_doInterimNotification") == true}
SequenceFlow_0my3p6y
SequenceFlow_0vluoaq
SequenceFlow_4
SequenceFlow_4
SequenceFlow_11
import org.onap.so.bpmn.common.scripts.*
def exUtil = new ExceptionUtil()
exUtil.processSubflowsBPMNException(execution)
SequenceFlow_11