Commit 99fb42ae authored by Anastasios Poimenidis's avatar Anastasios Poimenidis
Browse files

feat: introduce registry api subprocess flow in ossServiceOrderProcess.bpmn2... 

feat: introduce registry api subprocess flow in ossServiceOrderProcess.bpmn2 and k8sServiceOrderProcess.bpmn2 to obtain organization credentials
parent 126ad35a

src/main/resources/diagrams/ossClient/clientSubprocesses/terminate/ossServiceTerminationSubprocess.bpmn2

+95 −34
Changes for src/main/resources/diagrams/ossClient/clientSubprocesses/terminate/ossServiceTerminationSubprocess.bpmn2: 95 added lines, 34 removed lines.
Original line number Diff line number Diff line 
<?xml version="1.0" encoding="UTF-8"?>

<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:bpsim="http://www.bpsim.org/schemas/1.0" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:drools="http://www.jboss.org/drools" id="_0WSk0IfyED6zMoBzdD954g" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd http://www.jboss.org/drools drools.xsd http://www.bpsim.org/schemas/1.0 bpsim.xsd http://www.omg.org/spec/DD/20100524/DC DC.xsd http://www.omg.org/spec/DD/20100524/DI DI.xsd " exporter="jBPM Process Modeler" exporterVersion="2.0" targetNamespace="http://www.omg.org/bpmn20">

<bpmn2:definitions xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:bpsim="http://www.bpsim.org/schemas/1.0" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:drools="http://www.jboss.org/drools" id="_Yk0lkFz0ED-hs6nV7vQ9gw" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd http://www.jboss.org/drools drools.xsd http://www.bpsim.org/schemas/1.0 bpsim.xsd http://www.omg.org/spec/DD/20100524/DC DC.xsd http://www.omg.org/spec/DD/20100524/DI DI.xsd " exporter="jBPM Process Modeler" exporterVersion="2.0" targetNamespace="http://www.omg.org/bpmn20">

  <bpmn2:itemDefinition id="_requestedTerminationDateItem" structureRef="String"/>

  <bpmn2:itemDefinition id="_serviceTerminationDataWithTimerItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer"/>

  <bpmn2:itemDefinition id="_serviceTerminationDataItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationData"/>
@@ -18,7 +18,9 @@ 
  <bpmn2:itemDefinition id="__3CFB0323-2944-45FE-8140-39B02F9E4DFD_requestedTerminationDateOutputXItem" structureRef="String"/>

  <bpmn2:itemDefinition id="__D8AE084A-68DC-4DD0-9D04-C69D1550C1D0_serviceTerminationDataWithTimerInputXItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer"/>

  <bpmn2:itemDefinition id="__D8AE084A-68DC-4DD0-9D04-C69D1550C1D0_serviceTerminationDataResponseInputXItem" structureRef="org.etsi.osl.hypo.core.common.oss.client.ServiceTerminationDataResponse"/>

  <bpmn2:message id="_0WUaAIfyED6zMoBzdD954g" itemRef="tmf-process-infoType" name="tmf-process-info"/>

  <bpmn2:itemDefinition id="__B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectInputXItem" structureRef="org.etsi.osl.hypo.core.common.ServiceBaseOrganizationObject"/>

  <bpmn2:itemDefinition id="__B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectOutputXItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationData"/>

  <bpmn2:message id="_Yk1zsFz0ED-hs6nV7vQ9gw" itemRef="tmf-process-infoType" name="tmf-process-info"/>

  <bpmn2:message id="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83_InMessage" itemRef="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83_InMessageType"/>

  <bpmn2:message id="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83_OutMessage" itemRef="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83_OutMessageType"/>

  <bpmn2:interface id="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83_ServiceInterface" name="converters.ServiceOrderUpdateHandler" implementationRef="converters.ServiceOrderUpdateHandler">
@@ -35,11 +37,11 @@ 
      <bpmn2:outMessageRef>_3CFB0323-2944-45FE-8140-39B02F9E4DFD_OutMessage</bpmn2:outMessageRef>

    </bpmn2:operation>

  </bpmn2:interface>

  <bpmn2:collaboration id="_D51F9EF6-ECE8-4043-A005-A1C0201943DF" name="Default Collaboration">

    <bpmn2:participant id="_70B5CF9A-B876-428E-8380-C5C779EF3738" name="Pool Participant" processRef="ossServiceTerminationSubprocess"/>

  <bpmn2:collaboration id="_AF557CD0-FC80-4790-868B-2F2A7CADF2ED" name="Default Collaboration">

    <bpmn2:participant id="_B9658982-1ED5-44A2-8B28-45D29E782E3F" name="Pool Participant" processRef="ossServiceTerminationSubprocess"/>

  </bpmn2:collaboration>

  <bpmn2:process id="ossServiceTerminationSubprocess" drools:packageName="diagrams" drools:version="1.0" drools:adHoc="false" name="ossServiceTerminationSubprocess" isExecutable="true" processType="Public">

    <bpmn2:documentation><![CDATA[The process that triggers Oss Client to update the termination date of the 5G service]]></bpmn2:documentation>

    <bpmn2:documentation><![CDATA[The process that triggers Oss Client to update the termination date of the Oss service]]></bpmn2:documentation>

    <bpmn2:property id="requestedTerminationDate" itemSubjectRef="_requestedTerminationDateItem" name="requestedTerminationDate"/>

    <bpmn2:property id="serviceTerminationDataWithTimer" itemSubjectRef="_serviceTerminationDataWithTimerItem" name="serviceTerminationDataWithTimer"/>

    <bpmn2:property id="serviceTerminationData" itemSubjectRef="_serviceTerminationDataItem" name="serviceTerminationData"/>
@@ -53,7 +55,14 @@ 
        </drools:metaData>

      </bpmn2:extensionElements>

    </bpmn2:sequenceFlow>

    <bpmn2:sequenceFlow id="_7854E3DF-8283-4352-8B46-207443EB7C1E" sourceRef="_42E4795A-49B6-4234-B55B-3C7FA6F95006" targetRef="_4E6C6249-1F9F-45A7-9F34-4D15E435917D">

    <bpmn2:sequenceFlow id="_A52E86FB-B98F-456E-B298-33F72123B9F0" sourceRef="_B0565497-2D1C-4EDF-9999-2BCC7551D210" targetRef="_4E6C6249-1F9F-45A7-9F34-4D15E435917D">

      <bpmn2:extensionElements>

        <drools:metaData name="isAutoConnection.target">

          <drools:metaValue><![CDATA[true]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

    </bpmn2:sequenceFlow>

    <bpmn2:sequenceFlow id="_7854E3DF-8283-4352-8B46-207443EB7C1E" sourceRef="_42E4795A-49B6-4234-B55B-3C7FA6F95006" targetRef="_B0565497-2D1C-4EDF-9999-2BCC7551D210">

      <bpmn2:extensionElements>

        <drools:metaData name="isAutoConnection.target">

          <drools:metaValue><![CDATA[true]]></drools:metaValue>
@@ -69,6 +78,33 @@ 
      </bpmn2:extensionElements>

    </bpmn2:sequenceFlow>

    <bpmn2:sequenceFlow id="_9C75AB43-9B55-489B-A047-3C95C7744CCC" sourceRef="_4DABA446-012C-4882-85F9-ECDCF25C36A4" targetRef="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83"/>

    <bpmn2:callActivity id="_B0565497-2D1C-4EDF-9999-2BCC7551D210" drools:independent="false" drools:waitForCompletion="true" name="Obtain Organization Credentials" calledElement="registryPopulateOrganizationCredentials">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[Obtain Organization Credentials]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_7854E3DF-8283-4352-8B46-207443EB7C1E</bpmn2:incoming>

      <bpmn2:outgoing>_A52E86FB-B98F-456E-B298-33F72123B9F0</bpmn2:outgoing>

      <bpmn2:ioSpecification>

        <bpmn2:dataInput id="_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectInputX" drools:dtype="org.etsi.osl.hypo.core.common.ServiceBaseOrganizationObject" itemSubjectRef="__B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectInputXItem" name="serviceBaseOrganizationObject"/>

        <bpmn2:dataOutput id="_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectOutputX" drools:dtype="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationData" itemSubjectRef="__B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectOutputXItem" name="serviceBaseOrganizationObject"/>

        <bpmn2:inputSet>

          <bpmn2:dataInputRefs>_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectInputX</bpmn2:dataInputRefs>

        </bpmn2:inputSet>

        <bpmn2:outputSet>

          <bpmn2:dataOutputRefs>_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectOutputX</bpmn2:dataOutputRefs>

        </bpmn2:outputSet>

      </bpmn2:ioSpecification>

      <bpmn2:dataInputAssociation>

        <bpmn2:sourceRef>serviceTerminationData</bpmn2:sourceRef>

        <bpmn2:targetRef>_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectInputX</bpmn2:targetRef>

      </bpmn2:dataInputAssociation>

      <bpmn2:dataOutputAssociation>

        <bpmn2:sourceRef>_B0565497-2D1C-4EDF-9999-2BCC7551D210_serviceBaseOrganizationObjectOutputX</bpmn2:sourceRef>

        <bpmn2:targetRef>serviceTerminationData</bpmn2:targetRef>

      </bpmn2:dataOutputAssociation>

    </bpmn2:callActivity>

    <bpmn2:callActivity id="_D8AE084A-68DC-4DD0-9D04-C69D1550C1D0" drools:independent="false" drools:waitForCompletion="true" name="Send Message to TMF" calledElement="k8sAnd5GTerminationMessagesHandler">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">
@@ -139,7 +175,7 @@ 
          <drools:metaValue><![CDATA[Call Oss Client]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_7854E3DF-8283-4352-8B46-207443EB7C1E</bpmn2:incoming>

      <bpmn2:incoming>_A52E86FB-B98F-456E-B298-33F72123B9F0</bpmn2:incoming>

      <bpmn2:outgoing>_A36AE228-DF39-4E93-8242-CA5CEFB80834</bpmn2:outgoing>

      <bpmn2:ioSpecification>

        <bpmn2:dataInput id="_4E6C6249-1F9F-45A7-9F34-4D15E435917D_serviceTerminationDataWithTimerInputX" drools:dtype="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer" itemSubjectRef="__4E6C6249-1F9F-45A7-9F34-4D15E435917D_serviceTerminationDataWithTimerInputXItem" name="serviceTerminationDataWithTimer"/>
@@ -203,20 +239,20 @@ 
      <bpmn2:inputSet>

        <bpmn2:dataInputRefs>_42E4795A-49B6-4234-B55B-3C7FA6F95006_serviceTerminationDataInputX</bpmn2:dataInputRefs>

      </bpmn2:inputSet>

      <bpmn2:messageEventDefinition drools:msgref="tmf-process-info" messageRef="_0WUaAIfyED6zMoBzdD954g"/>

      <bpmn2:messageEventDefinition drools:msgref="tmf-process-info" messageRef="_Yk1zsFz0ED-hs6nV7vQ9gw"/>

    </bpmn2:intermediateThrowEvent>

    <bpmn2:endEvent id="_0CF74356-5111-438B-91DC-1F371BC08B38" name="END: 5G Service Termination Process">

    <bpmn2:endEvent id="_0CF74356-5111-438B-91DC-1F371BC08B38" name="END: OSS Service Termination Process">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[END: 5G Service Termination Process]]></drools:metaValue>

          <drools:metaValue><![CDATA[END: OSS Service Termination Process]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_F0AD3575-DB14-4929-9EC1-303B569C242E</bpmn2:incoming>

    </bpmn2:endEvent>

    <bpmn2:startEvent id="_4DABA446-012C-4882-85F9-ECDCF25C36A4" name="START: 5G Service Termination Process">

    <bpmn2:startEvent id="_4DABA446-012C-4882-85F9-ECDCF25C36A4" name="START: OSS Service Termination Process">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[START: 5G Service Termination Process]]></drools:metaValue>

          <drools:metaValue><![CDATA[START: OSS Service Termination Process]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:outgoing>_9C75AB43-9B55-489B-A047-3C95C7744CCC</bpmn2:outgoing>
@@ -228,55 +264,60 @@ 
        <dc:Bounds height="56" width="56" x="180" y="111"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__0CF74356-5111-438B-91DC-1F371BC08B38" bpmnElement="_0CF74356-5111-438B-91DC-1F371BC08B38">

        <dc:Bounds height="56" width="56" x="1046" y="393"/>

        <dc:Bounds height="56" width="56" x="863" y="578"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__42E4795A-49B6-4234-B55B-3C7FA6F95006" bpmnElement="_42E4795A-49B6-4234-B55B-3C7FA6F95006">

        <dc:Bounds height="56" width="56" x="616" y="111"/>

        <dc:Bounds height="56" width="56" x="641" y="111"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__447BD63D-EFEF-475E-BAF1-981DB4ED1F83" bpmnElement="_447BD63D-EFEF-475E-BAF1-981DB4ED1F83">

        <dc:Bounds height="102" width="154" x="368" y="88"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__4E6C6249-1F9F-45A7-9F34-4D15E435917D" bpmnElement="_4E6C6249-1F9F-45A7-9F34-4D15E435917D">

        <dc:Bounds height="101" width="153" x="756.5" y="89"/>

        <dc:Bounds height="101" width="153" x="368.5" y="246.5"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__3CFB0323-2944-45FE-8140-39B02F9E4DFD" bpmnElement="_3CFB0323-2944-45FE-8140-39B02F9E4DFD">

        <dc:Bounds height="102" width="154" x="368" y="370"/>

        <dc:Bounds height="102" width="154" x="368" y="410"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__DBCB6943-A036-418E-B49B-10C9A0ADF4D8" bpmnElement="_DBCB6943-A036-418E-B49B-10C9A0ADF4D8">

        <dc:Bounds height="56" width="56" x="616" y="393"/>

        <dc:Bounds height="56" width="56" x="641" y="433"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__D8AE084A-68DC-4DD0-9D04-C69D1550C1D0" bpmnElement="_D8AE084A-68DC-4DD0-9D04-C69D1550C1D0">

        <dc:Bounds height="101" width="153" x="756" y="370.5"/>

        <dc:Bounds height="101" width="153" x="592" y="555.5"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__B0565497-2D1C-4EDF-9999-2BCC7551D210" bpmnElement="_B0565497-2D1C-4EDF-9999-2BCC7551D210">

        <dc:Bounds height="101" width="153" x="592.5" y="246"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNEdge id="edge_shape__4DABA446-012C-4882-85F9-ECDCF25C36A4_to_shape__447BD63D-EFEF-475E-BAF1-981DB4ED1F83" bpmnElement="_9C75AB43-9B55-489B-A047-3C95C7744CCC">

        <di:waypoint x="208" y="139"/>

        <di:waypoint x="445" y="139"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__D8AE084A-68DC-4DD0-9D04-C69D1550C1D0_to_shape__0CF74356-5111-438B-91DC-1F371BC08B38" bpmnElement="_F0AD3575-DB14-4929-9EC1-303B569C242E">

        <di:waypoint x="832.5" y="421"/>

        <di:waypoint x="1046" y="421"/>

        <di:waypoint x="668.5" y="606"/>

        <di:waypoint x="863" y="606"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__447BD63D-EFEF-475E-BAF1-981DB4ED1F83_to_shape__42E4795A-49B6-4234-B55B-3C7FA6F95006" bpmnElement="_CDB2AA39-42B2-453A-85E8-5339883E964B">

        <di:waypoint x="445" y="139"/>

        <di:waypoint x="644" y="139"/>

        <di:waypoint x="669" y="139"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__42E4795A-49B6-4234-B55B-3C7FA6F95006_to_shape__4E6C6249-1F9F-45A7-9F34-4D15E435917D" bpmnElement="_7854E3DF-8283-4352-8B46-207443EB7C1E">

        <di:waypoint x="644" y="139"/>

        <di:waypoint x="756.5" y="139.5"/>

      <bpmndi:BPMNEdge id="edge_shape__42E4795A-49B6-4234-B55B-3C7FA6F95006_to_shape__B0565497-2D1C-4EDF-9999-2BCC7551D210" bpmnElement="_7854E3DF-8283-4352-8B46-207443EB7C1E">

        <di:waypoint x="669" y="139"/>

        <di:waypoint x="669" y="246"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__B0565497-2D1C-4EDF-9999-2BCC7551D210_to_shape__4E6C6249-1F9F-45A7-9F34-4D15E435917D" bpmnElement="_A52E86FB-B98F-456E-B298-33F72123B9F0">

        <di:waypoint x="669" y="296.5"/>

        <di:waypoint x="521.5" y="297"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__4E6C6249-1F9F-45A7-9F34-4D15E435917D_to_shape__3CFB0323-2944-45FE-8140-39B02F9E4DFD" bpmnElement="_A36AE228-DF39-4E93-8242-CA5CEFB80834">

        <di:waypoint x="833" y="139.5"/>

        <di:waypoint x="832.9927608469679" y="268"/>

        <di:waypoint x="445" y="268"/>

        <di:waypoint x="445" y="370"/>

        <di:waypoint x="445" y="297"/>

        <di:waypoint x="445" y="410"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__3CFB0323-2944-45FE-8140-39B02F9E4DFD_to_shape__DBCB6943-A036-418E-B49B-10C9A0ADF4D8" bpmnElement="_287FFD7B-77B3-4F3B-982F-F2E1A825FFDB">

        <di:waypoint x="445" y="421"/>

        <di:waypoint x="644" y="421"/>

        <di:waypoint x="445" y="461"/>

        <di:waypoint x="669" y="461"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__DBCB6943-A036-418E-B49B-10C9A0ADF4D8_to_shape__D8AE084A-68DC-4DD0-9D04-C69D1550C1D0" bpmnElement="_E0DCD510-55C6-4001-A773-9819976C2C4D">

        <di:waypoint x="644" y="421"/>

        <di:waypoint x="832.5" y="421"/>

        <di:waypoint x="669" y="461"/>

        <di:waypoint x="668.5" y="606"/>

      </bpmndi:BPMNEdge>

    </bpmndi:BPMNPlane>

  </bpmndi:BPMNDiagram>
@@ -372,10 +413,30 @@ 
              </bpsim:UnitCost>

            </bpsim:CostParameters>

          </bpsim:ElementParameters>

          <bpsim:ElementParameters elementRef="_B0565497-2D1C-4EDF-9999-2BCC7551D210">

            <bpsim:TimeParameters>

              <bpsim:ProcessingTime>

                <bpsim:NormalDistribution mean="0" standardDeviation="0"/>

              </bpsim:ProcessingTime>

            </bpsim:TimeParameters>

            <bpsim:ResourceParameters>

              <bpsim:Availability>

                <bpsim:FloatingParameter value="0"/>

              </bpsim:Availability>

              <bpsim:Quantity>

                <bpsim:FloatingParameter value="0"/>

              </bpsim:Quantity>

            </bpsim:ResourceParameters>

            <bpsim:CostParameters>

              <bpsim:UnitCost>

                <bpsim:FloatingParameter value="0"/>

              </bpsim:UnitCost>

            </bpsim:CostParameters>

          </bpsim:ElementParameters>

        </bpsim:Scenario>

      </bpsim:BPSimData>

    </bpmn2:extensionElements>

    <bpmn2:source>_0WSk0IfyED6zMoBzdD954g</bpmn2:source>

    <bpmn2:target>_0WSk0IfyED6zMoBzdD954g</bpmn2:target>

    <bpmn2:source>_Yk0lkFz0ED-hs6nV7vQ9gw</bpmn2:source>

    <bpmn2:target>_Yk0lkFz0ED-hs6nV7vQ9gw</bpmn2:target>

  </bpmn2:relationship>

</bpmn2:definitions>
 
 No newline at end of file

src/main/resources/diagrams/ossClient/k8sOrders/k8sServiceOrderProcess.bpmn2

+89 −27

File changed.

Preview size limit exceeded, changes collapsed.

src/main/resources/diagrams/ossClient/clientSubprocesses/terminate/k8sServiceTerminationSubprocess.bpmn2→src/main/resources/diagrams/ossClient/k8sOrders/k8sServiceTerminationSubprocess.bpmn2

+39 −37

File changed and moved.

Preview size limit exceeded, changes collapsed.

src/main/resources/diagrams/ossClient/ossOrders/ossServiceOrderProcess.bpmn2

+127 −58

File changed.

Preview size limit exceeded, changes collapsed.

src/test/java/io/sonata/kafka/helpers/TestHelpers.java

+11 −0
Changes for src/test/java/io/sonata/kafka/helpers/TestHelpers.java: 11 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -5,6 +5,7 @@ import com.google.gson.JsonParser; 
import io.smallrye.mutiny.Multi;

import io.smallrye.mutiny.Uni;

import io.smallrye.reactive.messaging.memory.InMemorySink;

import io.sonata.kafka.supplier.ActiveProcessSupplier;

import io.sonata.kafka.supplier.HasReceivedMessagesSupplier;

import io.sonata.kafka.supplier.IsProcessCompletedSupplier;

import io.sonata.kafka.supplier.NumberOfProcessesSupplier;
@@ -66,6 +67,16 @@ public final class TestHelpers { 
                .last();

    }



    public static Uni<String> pollActiveProcess(Process<? extends Model> process) {

        return Multi.createBy()

                .repeating()

                .supplier(new ActiveProcessSupplier(process))

                .withDelay(Duration.ofMillis(100))

                .whilst(Objects::isNull)

                .collect()

                .last();

    }



    public static Uni<Boolean> pollProcessInstances(

            Process<? extends Model> process, int numberOfInstances) {

        return Multi.createBy()