tibco
/
test1
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
test1/ttt55.module/Processes/B_IN_A_B/FMKafkaReceiver.bwp

1750 lines
126 KiB
XML
Raw Permalink Blame History

<?xml version="1.0" encoding="UTF-8"?>
<bpws:process exitOnStandardFault="no"
name="B_IN_A_B.FMKafkaReceiver" suppressJoinFailure="yes"
targetNamespace="http://xmlns.example.com/20230908145211"
xmlns:bpws="http://docs.oasis-open.org/wsbpel/2.0/process/executable"
xmlns:info="http://www.tibco.com/bw/process/info"
xmlns:ns="http://www.tibco.com/pe/EngineTypes"
xmlns:ns0="http://www.onemdw.org/MainSchema"
xmlns:ns1="http://www.onemdw.org/SimpleMonitor"
xmlns:ns10="http://www.onemdw.org/LogSchema"
xmlns:ns2="http://www.tibco.com/namespaces/tnt/plugins/receiver+ee17425c-1680-4b0f-a554-45c43c65a549+KafkaReceiverMessageOutput"
xmlns:ns3="http://tns.tibco.com/bw/palette/internal/activityerror+bw.kafka.Receiver"
xmlns:ns4="http://lhg.ngmdw.bw.fwk/SFTPGoMFT"
xmlns:ns5="activity.jsonParser.input+24799963-9589-4f7b-a810-086f3463bcc0+ActivityInputType"
xmlns:ns6="http://tns.tibco.com/bw/json/1689939614651"
xmlns:ns7="http://schemas.tibco.com/bw/plugins/kafka/6.0/kafkaPluginExceptions"
xmlns:ns8="http://schemas.tibco.com/bw/plugins/xml/5.0/JSONActivitiesExceptions"
xmlns:ns9="http://tns.tibco.com/bw/palette/internal/activityerror+bw.restjson.JsonParser"
xmlns:sca="http://docs.oasis-open.org/ns/opencsa/sca/200912"
xmlns:sca-bpel="http://docs.oasis-open.org/ns/opencsa/sca-bpel/200801"
xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"
xmlns:tibprop="http://ns.tibco.com/bw/property" xmlns:xsd="http://www.w3.org/2001/XMLSchema">
<tibex:VariableDescriptor type="MemorySaving">
<task name="GetFile">
<endingVariables>
<variable>GetFile-input</variable>
<variable>GetFile</variable>
<variable>basePath</variable>
<variable>pathSeparator</variable>
<variable>inputDir</variable>
</endingVariables>
</task>
<task name="ParseJSON">
<endingVariables>
<variable>ParseJSON-input</variable>
</endingVariables>
</task>
<task name="LogSFTPGetFileError">
<endingVariables>
<variable>LogSFTPGetFileError-input</variable>
<variable>errorCodeGetSFTPFile</variable>
</endingVariables>
</task>
<task name="SetInterfaceMetadata">
<endingVariables>
<variable>SetInterfaceMetadata-input</variable>
<variable>maxRetry</variable>
<variable>continueOnError</variable>
<variable>retryTimeInSeconds</variable>
<variable>isCustomPreAction</variable>
<variable>isCustomPreDeliver</variable>
<variable>isCustomPostAction</variable>
<variable>isCustomErrorHandling</variable>
<variable>InterfaceName</variable>
</endingVariables>
</task>
<task name="LogMessageConfirmedInfo">
<endingVariables>
<variable>LogMessageConfirmedInfo-input</variable>
</endingVariables>
</task>
<task name="LogMessageReceivedDebug">
<endingVariables>
<variable>LogMessageReceivedDebug-input</variable>
</endingVariables>
</task>
<task name="LogKafkaError">
<endingVariables>
<variable>LogKafkaError-input</variable>
<variable>errorCodeKafkaConnection</variable>
<variable>errorCodeKafkaReceiveMessage</variable>
</endingVariables>
</task>
<task name="LogParseJSONError">
<endingVariables>
<variable>LogParseJSONError-input</variable>
<variable>errorCodeParseJSON</variable>
</endingVariables>
</task>
<task name="LogProcessingFileError">
<endingVariables>
<variable>LogProcessingFileError-input</variable>
<variable>FaultDetails</variable>
<variable>errorCodeUnexpected</variable>
</endingVariables>
</task>
</tibex:VariableDescriptor>
<tibex:Types>
<xs:schema attributeFormDefault="unqualified"
elementFormDefault="qualified"
targetNamespace="http://www.tibco.com/pe/EngineTypes"
xmlns:tns="http://www.tibco.com/pe/EngineTypes" xmlns:xs="http://www.w3.org/2001/XMLSchema">
<xs:complexType block="extension restriction"
final="extension restriction" name="ErrorReport">
<xs:sequence>
<xs:element
block="extension restriction substitution"
form="unqualified" name="StackTrace" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="Msg" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="FullClass" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="Class" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="ProcessStack" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="MsgCode" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="Data" type="tns:anydata"/>
</xs:sequence>
</xs:complexType>
<xs:complexType block="extension restriction"
final="extension restriction" name="OptionalErrorReport">
<xs:sequence>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0"
name="StackTrace" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="Msg" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0"
name="FullClass" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="Class" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0"
name="ProcessStack" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="MsgCode" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="Data" type="tns:anydata"/>
</xs:sequence>
</xs:complexType>
<xs:complexType block="extension restriction"
final="extension restriction" name="FaultDetail">
<xs:sequence>
<xs:element
block="extension restriction substitution"
form="unqualified" name="ActivityName" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0" name="Data" type="tns:anydata"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="Msg" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="MsgCode" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="ProcessStack" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="StackTrace" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="FullClass" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="Class" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType block="extension restriction"
final="extension restriction" name="ProcessContext">
<xs:sequence>
<xs:element
block="extension restriction substitution"
form="unqualified" name="JobId" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="ApplicationName" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="EngineName" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" name="ProcessInstanceId" type="xs:string"/>
<xs:element
block="extension restriction substitution"
form="unqualified" minOccurs="0"
name="CustomJobId" type="xs:string"/>
<!--xs:element name="RestartedFromCheckpoint" form="unqualified" block="extension restriction substitution" type="xs:boolean"/-->
<xs:element
block="extension restriction substitution"
form="unqualified" maxOccurs="unbounded"
minOccurs="0" name="TrackingInfo" type="xs:string"/>
</xs:sequence>
</xs:complexType>
<xs:complexType block="extension restriction"
final="extension restriction" name="anydata">
<xs:sequence>
<xs:any namespace="##any" processContents="lax"/>
</xs:sequence>
</xs:complexType>
<xs:element block="extension restriction substitution"
final="extension restriction" name="OptionalErrorReport" type="tns:OptionalErrorReport"/>
<xs:element block="extension restriction substitution"
final="extension restriction" name="ErrorReport" type="tns:ErrorReport"/>
<xs:element block="extension restriction substitution"
final="extension restriction" name="FaultDetail" type="tns:FaultDetail"/>
<xs:element block="extension restriction substitution"
final="extension restriction" name="ProcessContext" type="tns:ProcessContext"/>
<xs:element block="extension restriction substitution"
final="extension restriction" name="CorrelationValue" type="xs:string"/>
</xs:schema>
<schema attributeFormDefault="unqualified"
elementFormDefault="unqualified"
targetNamespace="http://schemas.tibco.com/bw/pe/plugin/5.0/exceptions"
version="" xmlns="http://www.w3.org/2001/XMLSchema" xmlns:tns="http://schemas.tibco.com/bw/pe/plugin/5.0/exceptions">
<complexType name="ActivityExceptionType">
<sequence>
<element name="msg" type="string"/>
<element minOccurs="0" name="msgCode" type="string"/>
</sequence>
</complexType>
<element name="ActivityException" type="tns:ActivityExceptionType"/>
<complexType name="ActivityTimedOutExceptionType">
<complexContent>
<extension base="tns:ActivityExceptionType"/>
</complexContent>
</complexType>
<element name="ActivityTimedOutException" type="tns:ActivityTimedOutExceptionType"/>
<complexType name="DuplicateKeyExceptionType">
<complexContent>
<extension base="tns:ActivityExceptionType">
<sequence>
<element name="duplicateKey" type="string"/>
<element minOccurs="0" name="previousJobID" type="string"/>
</sequence>
</extension>
</complexContent>
</complexType>
<element name="DuplicateKeyException" type="tns:DuplicateKeyExceptionType"/>
</schema>
<schema
targetNamespace="http://www.tibco.com/namespaces/tnt/plugins/receiver+ee17425c-1680-4b0f-a554-45c43c65a549+KafkaReceiverMessageOutput"
xmlns="http://www.w3.org/2001/XMLSchema" xmlns:tns="http://www.tibco.com/namespaces/tnt/plugins/receiver+ee17425c-1680-4b0f-a554-45c43c65a549+KafkaReceiverMessageOutput">
<complexType name="KafkaReceiverMessageOutput">
<sequence>
<element maxOccurs="1" minOccurs="1" name="topic" type="string"/>
<element maxOccurs="1" minOccurs="0"
name="partition" type="long"/>
<element maxOccurs="1" minOccurs="1" name="offset" type="long"/>
<element maxOccurs="1" minOccurs="0" name="key" type="string"/>
<element maxOccurs="1" minOccurs="1" name="message" type="string"/>
<element maxOccurs="1" minOccurs="0" name="headers">
<complexType>
<sequence>
<element maxOccurs="2147483647"
minOccurs="0" name="header">
<complexType>
<sequence>
<element maxOccurs="1"
minOccurs="1" name="key" type="string"/>
<element maxOccurs="1"
minOccurs="1"
name="value" type="base64Binary"/>
</sequence>
</complexType>
</element>
</sequence>
</complexType>
</element>
<element maxOccurs="1" minOccurs="0" name="errorInfo">
<complexType>
<sequence>
<element maxOccurs="1" minOccurs="0"
name="keyErrorStackTrace" type="string"/>
<element maxOccurs="1" minOccurs="0"
name="keyErrorPayload" type="base64Binary"/>
<element maxOccurs="1" minOccurs="0"
name="valueErrorStackTrace" type="string"/>
<element maxOccurs="1" minOccurs="0"
name="valueErrorPayload" type="base64Binary"/>
</sequence>
</complexType>
</element>
</sequence>
</complexType>
<element name="KafkaReceiverMessageOutput" type="tns:KafkaReceiverMessageOutput"/>
</schema>
<schema elementFormDefault="unqualified"
targetNamespace="http://schemas.tibco.com/bw/plugins/kafka/6.0/kafkaPluginExceptions"
xmlns="http://www.w3.org/2001/XMLSchema" xmlns:tns="http://schemas.tibco.com/bw/plugins/kafka/6.0/kafkaPluginExceptions">
<complexType name="BaseExceptionType">
<sequence>
<element name="msg" type="string"/>
<element minOccurs="0" name="msgCode" type="string"/>
</sequence>
</complexType>
<complexType name="kafkaPluginExceptionType">
<complexContent>
<extension base="tns:BaseExceptionType"/>
</complexContent>
</complexType>
<complexType name="kafkaEventSourceFaultExceptionType">
<complexContent>
<extension base="tns:BaseExceptionType"/>
</complexContent>
</complexType>
<complexType name="KafkaCreatedProducerExceptionType">
<complexContent>
<extension base="tns:BaseExceptionType"/>
</complexContent>
</complexType>
<element name="KafkaCreatedProducerException" type="tns:KafkaCreatedProducerExceptionType"/>
<element name="KafkaPluginException" type="tns:kafkaPluginExceptionType"/>
<element name="KafkaEventSourceFaultException" type="tns:kafkaEventSourceFaultExceptionType"/>
</schema>
<schema elementFormDefault="unqualified"
targetNamespace="activity.jsonParser.input+24799963-9589-4f7b-a810-086f3463bcc0+ActivityInputType"
xmlns="http://www.w3.org/2001/XMLSchema" xmlns:tns="activity.jsonParser.input+24799963-9589-4f7b-a810-086f3463bcc0+ActivityInputType">
<complexType name="ActivityInputClassType">
<sequence>
<element maxOccurs="1" minOccurs="1"
name="jsonString" type="string"/>
</sequence>
</complexType>
<element name="ActivityInputClass" type="tns:ActivityInputClassType"/>
</schema>
<schema elementFormDefault="unqualified"
targetNamespace="http://tns.tibco.com/bw/palette/internal/activityerror+bw.kafka.Receiver"
xmlns="http://www.w3.org/2001/XMLSchema"
xmlns:Q1="http://schemas.tibco.com/bw/plugins/kafka/6.0/kafkaPluginExceptions" xmlns:tns="http://tns.tibco.com/bw/palette/internal/activityerror+bw.kafka.Receiver">
<import namespace="http://schemas.tibco.com/bw/plugins/kafka/6.0/kafkaPluginExceptions"/>
<element name="ActivityErrorData" type="tns:ActivityErrorDataType"/>
<complexType name="ActivityErrorDataType">
<choice>
<element maxOccurs="1" minOccurs="0" ref="Q1:KafkaEventSourceFaultException"/>
</choice>
</complexType>
</schema>
<schema elementFormDefault="unqualified"
targetNamespace="http://schemas.tibco.com/bw/plugins/xml/5.0/JSONActivitiesExceptions"
xmlns="http://www.w3.org/2001/XMLSchema" xmlns:tns="http://schemas.tibco.com/bw/plugins/xml/5.0/JSONActivitiesExceptions">
<element name="JSONActivityException" type="tns:JSONActivityException"/>
<complexType name="JSONActivityException">
<sequence>
<element name="msg" type="string"/>
<element minOccurs="0" name="msgCode" type="string"/>
</sequence>
</complexType>
<element name="UnsupportedEncodingException" type="tns:UnsupportedEncodingExceptionType"/>
<complexType name="UnsupportedEncodingExceptionType">
<complexContent>
<extension base="tns:JSONActivityException">
<sequence>
<element name="encoding" type="string"/>
</sequence>
</extension>
</complexContent>
</complexType>
<complexType name="JSONParserExceptionType">
<complexContent>
<extension base="tns:JSONActivityException"/>
</complexContent>
</complexType>
<element name="JSONParserException" type="tns:JSONParserExceptionType"/>
<complexType name="JSONTransformExceptionType">
<complexContent>
<extension base="tns:JSONActivityException"/>
</complexContent>
</complexType>
<element name="JSONTransformException" type="tns:JSONTransformExceptionType"/>
<complexType name="JSONRenderExceptionType">
<complexContent>
<extension base="tns:JSONActivityException"/>
</complexContent>
</complexType>
<element name="JSONRenderException" type="tns:JSONRenderExceptionType"/>
<complexType name="JSONRestExceptionType">
<complexContent>
<extension base="tns:JSONActivityException"/>
</complexContent>
</complexType>
<element name="JSONRestException" type="tns:JSONRestExceptionType"/>
<complexType name="ValidationExceptionType">
<complexContent>
<extension base="tns:JSONActivityException"/>
</complexContent>
</complexType>
<element name="ValidationException" type="tns:ValidationExceptionType"/>
</schema>
<schema elementFormDefault="unqualified"
targetNamespace="http://tns.tibco.com/bw/palette/internal/activityerror+bw.restjson.JsonParser"
xmlns="http://www.w3.org/2001/XMLSchema"
xmlns:Q1="http://schemas.tibco.com/bw/plugins/xml/5.0/JSONActivitiesExceptions" xmlns:tns="http://tns.tibco.com/bw/palette/internal/activityerror+bw.restjson.JsonParser">
<import namespace="http://schemas.tibco.com/bw/plugins/xml/5.0/JSONActivitiesExceptions"/>
<element name="ActivityErrorData" type="tns:ActivityErrorDataType"/>
<complexType name="ActivityErrorDataType">
<choice>
<element maxOccurs="1" minOccurs="0" ref="Q1:JSONParserException"/>
</choice>
</complexType>
</schema>
</tibex:Types>
<tibex:ProcessInfo callable="false" createdBy="U534715"
createdOn="Fri Sep 08 14:52:11 CEST 2023" description=""
extraErrorVars="true" modifiers="public"
productVersion="2.8.2 V17 2023-05-19" scalable="false"
singleton="true" stateless="true" type="IT"/>
<tibex:ProcessInterface context="" input="" output=""/>
<tibex:ProcessTemplateConfigurations/>
<notation:Diagram measurementUnit="Pixel" type="BWProcess"
xmlns:bwnotation="http://tns.tibco.com/bw/runtime/BWNotation"
xmlns:notation="http://www.eclipse.org/gmf/runtime/1.0.2/notation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<children type="2001">
<children type="5001"/>
<children type="3001">
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
<element href="//0/@process"/>
</children>
<children type="3002">
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<children type="3003">
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<children type="3004">
<children type="4018">
<children type="3018">
<children type="4020">
<children type="3020">
<children type="4005">
<children type="3007">
<children type="4002 bw.kafka.Receiver">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.0"/>
<layoutConstraint
height="40" width="40"
x="24"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.1"/>
<layoutConstraint x="547"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002 bw.restjson.JsonParser">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.2"/>
<layoutConstraint
height="40" width="40"
x="138"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002 bw.generalactivities.confirm">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.3"/>
<layoutConstraint
height="40" width="40"
x="644"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.4"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.4"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.4"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.4"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.4"/>
<layoutConstraint
width="207" x="505"
xsi:type="notation:Bounds" y="166"/>
</children>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.5"/>
<layoutConstraint
width="202" x="248"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002 bw.generalactivities.confirm">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.6"/>
<layoutConstraint
height="40" width="152"
x="792"
xsi:type="notation:Bounds" y="166"/>
</children>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.7"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.7"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.7"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@activity/@activities.7"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.7"/>
<layoutConstraint
width="230" x="753"
xsi:type="notation:Bounds" y="40"/>
</children>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@activity/@activities.8"/>
<layoutConstraint x="287"
xsi:type="notation:Bounds" y="182"/>
</children>
<styles xsi:type="notation:DrawerStyle"/>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
<element href="//0/@process/@activity/@activity"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@activity"/>
<layoutConstraint height="341"
width="1012" xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI" lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity"/>
<layoutConstraint height="341" width="1015" xsi:type="notation:Bounds"/>
</children>
<children type="4022">
<children type="3022">
<children type="4028">
<children type="3029">
<children type="4032">
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0"/>
<layoutConstraint
height="34" width="34"
xsi:type="notation:Bounds" y="68"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<children type="3030">
<children type="4005">
<children type="3007">
<eAnnotations source="Pixel"/>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity/@activities.0"/>
<layoutConstraint
x="47"
xsi:type="notation:Bounds" y="58"/>
</children>
<styles xsi:type="notation:DrawerStyle"/>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0/@activity/@activity"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles restoreHeight="181"
restoreWidth="965" xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.0"/>
<layoutConstraint height="181"
width="965" xsi:type="notation:Bounds"/>
</children>
<children type="4028">
<children type="3029">
<children type="4032">
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1"/>
<layoutConstraint
height="34" width="34"
xsi:type="notation:Bounds" y="68"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<children type="3030">
<children type="4005">
<children type="3007">
<eAnnotations source="Pixel"/>
<eAnnotations source="Pixel"/>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.0"/>
<layoutConstraint
width="157"
x="28"
xsi:type="notation:Bounds" y="50"/>
</children>
<children type="4002 bw.generalactivities.confirm">
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName=".AppleSystemUIFont"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@activities.1"/>
<layoutConstraint
height="40"
width="134"
x="242"
xsi:type="notation:Bounds" y="50"/>
</children>
<styles xsi:type="notation:DrawerStyle"/>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity"/>
<layoutConstraint
height="191" width="914" xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles restoreHeight="180"
restoreWidth="965"
restoreY="180" xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1"/>
<layoutConstraint height="199"
width="965"
xsi:type="notation:Bounds" y="181"/>
</children>
<children type="4029">
<children type="3031">
<children type="4033">
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll"/>
<layoutConstraint
height="34" width="34"
xsi:type="notation:Bounds" y="68"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<children type="3032">
<children type="4005">
<children type="3007">
<eAnnotations source="Pixel"/>
<children type="4002">
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<children type="4017">
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity/@activities.0"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles
fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity/@activities.0"/>
<layoutConstraint
width="191"
x="9"
xsi:type="notation:Bounds" y="42"/>
</children>
<styles xsi:type="notation:DrawerStyle"/>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles
backgroundColor="16777215"
gradientEndColor="50431"
gradientStartColor="16777215" xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll/@activity/@activity"/>
<layoutConstraint
height="173" width="914" xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI"
lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catchAll"/>
<layoutConstraint xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
</children>
<styles fontName="Segoe UI" lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity/@faultHandlers"/>
<layoutConstraint height="586" width="975"
x="22" xsi:type="notation:Bounds" y="407"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
<element href="//0/@process/@activity"/>
</children>
<styles fontName="Segoe UI" lineColor="0" xsi:type="notation:ShapeStyle"/>
<styles xsi:type="bwnotation:BackgroundStyle"/>
<styles xsi:type="bwnotation:ResizingStyle"/>
<element href="//0/@process/@activity"/>
<layoutConstraint height="928" width="1015" x="1"
xsi:type="notation:Bounds" y="1"/>
</children>
<styles xsi:type="notation:SortingStyle"/>
<styles xsi:type="notation:FilteringStyle"/>
<element href="//0/@process"/>
</children>
<styles fontName="Segoe UI" lineColor="0" xsi:type="notation:ShapeStyle"/>
<element href="//0/@process"/>
<layoutConstraint height="980" width="1357" xsi:type="notation:Bounds"/>
</children>
<styles xsi:type="notation:DiagramStyle"/>
<element href="//0"/>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.2" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.0"/>
<bendpoints points="[9, 0, -105, -20]$[104, 0, -10, -20]" xsi:type="notation:RelativeBendpoints"/>
<sourceAnchor id="(0.8163265306122449,0.32653061224489793)" xsi:type="notation:IdentityAnchor"/>
<targetAnchor id="(0.20408163265306123,0.7346938775510204)" xsi:type="notation:IdentityAnchor"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.1"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.3" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName=".AppleSystemUIFont" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.1"/>
<bendpoints points="[25, 0, -99, 8]$[100, 0, -24, 8]" xsi:type="notation:RelativeBendpoints"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.2"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.5" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName=".AppleSystemUIFont" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.2"/>
<bendpoints points="[0, 0, 0, 0]$[0, 0, 0, 0]" xsi:type="notation:RelativeBendpoints"/>
<targetAnchor id="(0.16326530612244897,0.5102040816326531)" xsi:type="notation:IdentityAnchor"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.1"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.4" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="255" xsi:type="notation:ConnectorStyle"/>
<styles fontColor="255" fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.3"/>
<bendpoints points="[0, 25, 0, -101]$[0, 102, 0, -24]" xsi:type="notation:RelativeBendpoints"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.5"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.8" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.4"/>
<bendpoints points="[25, 0, -239, 0]$[240, 0, -24, 0]" xsi:type="notation:RelativeBendpoints"/>
<targetAnchor id="(0.5306122448979592,0.04081632653061224)" xsi:type="notation:IdentityAnchor"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.8"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.1" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.5"/>
<bendpoints
points="[73, 0, -185, 134]$[126, 0, -132, 134]$[126, -134, -132, 0]$[234, -134, -24, 0]" xsi:type="notation:RelativeBendpoints"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.1/@children.0/@children.1/@children.1/@children.0/@children.0/@children.0"
target="//@children.0/@children.4/@children.0/@children.0/@children.1/@children.0/@children.1/@children.1/@children.0/@children.0/@children.1" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@faultHandlers/@catch.1/@activity/@activity/@links/@children.0"/>
<bendpoints points="[42, 0, -161, 0]$[173, 0, -30, 0]" xsi:type="notation:RelativeBendpoints"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.4"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.6" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.6"/>
<bendpoints points="[25, 0, -96, 0]$[91, 0, -30, 0]" xsi:type="notation:RelativeBendpoints"/>
</edges>
<edges
source="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.3"
target="//@children.0/@children.4/@children.0/@children.0/@children.0/@children.0/@children.0/@children.0/@children.7" type="4006">
<children type="6002">
<layoutConstraint xsi:type="notation:Location" y="40"/>
</children>
<styles lineColor="0" xsi:type="notation:ConnectorStyle"/>
<styles fontName="Segoe UI" xsi:type="notation:FontStyle"/>
<element href="//0/@process/@activity/@activity/@links/@children.7"/>
<bendpoints points="[25, 0, -136, 0]$[137, 0, -24, 0]" xsi:type="notation:RelativeBendpoints"/>
</edges>
</notation:Diagram>
<tibex:NamespaceRegistry enabled="true">
<tibex:namespaceItem
namespace="activity.jsonParser.input+____UUID____+ActivityInputType" prefix="tns4"/>
<tibex:namespaceItem
namespace="http://www.onemdw.org/MainSchema" prefix="tns1"/>
<tibex:namespaceItem
namespace="http://www.tibco.com/bw/xpath/bw-custom-functions" prefix="bw"/>
<tibex:namespaceItem
namespace="http://www.onemdw.org/SimpleMonitor" prefix="tns2"/>
<tibex:namespaceItem
namespace="http://tns.tibco.com/bw/json/1689939614651" prefix="tns5"/>
<tibex:namespaceItem
namespace="http://www.example.org/MonitorSchema" prefix="tns"/>
</tibex:NamespaceRegistry>
<bpws:import importType="http://www.w3.org/2001/XMLSchema" namespace="http://lhg.ngmdw.bw.fwk/SFTPGoMFT"/>
<bpws:import importType="http://www.w3.org/2001/XMLSchema" namespace="http://tns.tibco.com/bw/json/1689939614651"/>
<bpws:import importType="http://www.w3.org/2001/XMLSchema" namespace="http://www.onemdw.org/MainSchema"/>
<bpws:import importType="http://www.w3.org/2001/XMLSchema" namespace="http://www.onemdw.org/SimpleMonitor"/>
<bpws:import importType="http://www.w3.org/2001/XMLSchema" namespace="http://www.example.org/MonitorSchema"/>
<bpws:variables>
<bpws:variable element="ns:ProcessContext"
name="_processContext" sca-bpel:internal="true"/>
<bpws:variable name="KafkaProperty" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
sca-bpel:sharedResourceType="{http://ns.tibco.com/bw/sharedresource/kafka}KafkaConnection" type="xsd:string">
<bpws:from>
<bpws:literal>kafka.KafkaConnectionResource</bpws:literal>
</bpws:from>
</bpws:variable>
<bpws:variable name="maxRetry" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/DeliverConfig/maxRetry" type="xsd:int"/>
<bpws:variable name="continueOnError" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/DeliverConfig/continueOnError" type="xsd:boolean"/>
<bpws:variable name="retryTimeInSeconds"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/DeliverConfig/retryTimeInSeconds" type="xsd:int"/>
<bpws:variable name="isCustomPreAction"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/Extensions/isCustomPreAction" type="xsd:boolean"/>
<bpws:variable name="isCustomPreDeliver"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/Extensions/isCustomPreDeliver" type="xsd:boolean"/>
<bpws:variable name="isCustomPostAction"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/Extensions/isCustomPostAction" type="xsd:boolean"/>
<bpws:variable name="isCustomErrorHandling"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/Extensions/isCustomErrorHandling" type="xsd:boolean"/>
<bpws:variable name="basePath" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/Paths/BaseFolderPath" type="xsd:string"/>
<bpws:variable name="InterfaceName" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/InterfaceName" type="xsd:string"/>
<bpws:variable element="ns2:KafkaReceiverMessageOutput"
name="KafkaReceiveMessage" sca-bpel:internal="true"/>
<bpws:variable name="consumerGroup" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/InputConnectionKafka/consumerGroup" type="xsd:string"/>
<bpws:variable name="topicName" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/InputConnectionKafka/topicName" type="xsd:string"/>
<bpws:variable element="ns3:ActivityErrorData"
name="_error_KafkaReceiveMessage" sca-bpel:internal="true"/>
<bpws:variable name="pathSeparator" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="//bwce-fwk///System/pathSeparator" type="xsd:string"/>
<bpws:variable name="inputDir" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="//bwce-fwk///Main/inputDir" type="xsd:string"/>
<bpws:variable element="ns4:GetFileInput" name="GetFile-input" sca-bpel:internal="true"/>
<bpws:variable element="ns4:GetFileOutput" name="GetFile" sca-bpel:internal="true"/>
<bpws:variable element="ns5:ActivityInputClass"
name="ParseJSON-input" sca-bpel:internal="true"/>
<bpws:variable element="ns6:FileDispatcherInputElement"
name="ParseJSON" sca-bpel:internal="true"/>
<bpws:variable name="LogPayloadEnabled"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="//bwce-fwk///Logging/LogPayloadEnabled" type="xsd:boolean"/>
<bpws:variable element="ns1:errorReport"
name="LogSFTPGetFileError-input" sca-bpel:internal="true"/>
<bpws:variable element="ns0:initInput"
name="SetInterfaceMetadata-input" sca-bpel:internal="true"/>
<bpws:variable name="FaultName" sca-bpel:internal="true" type="xsd:string"/>
<bpws:variable element="ns:ErrorReport" name="_error" sca-bpel:internal="true"/>
<bpws:variable element="ns:OptionalErrorReport"
name="_errorOptional" sca-bpel:internal="true"/>
<bpws:variable name="FaultName1" sca-bpel:internal="true" type="xsd:string"/>
<bpws:variable element="ns:FaultDetail" name="FaultDetails" sca-bpel:internal="true"/>
<bpws:variable element="ns1:errorReport"
name="LogProcessingFileError-input" sca-bpel:internal="true"/>
<bpws:variable element="ns1:errorReport"
name="LogKafkaError-input" sca-bpel:internal="true"/>
<bpws:variable name="errorCodeKafkaConnection"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ErrorCodes/KafkaConnection" type="xsd:string"/>
<bpws:variable element="ns1:errorReport"
name="LogParseJSONError-input" sca-bpel:internal="true"/>
<bpws:variable name="errorCodeParseJSON"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ErrorCodes/ParseJSON" type="xsd:string"/>
<bpws:variable name="errorCodeKafkaReceiveMessage"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ErrorCodes/KafkaReceiveMessage" type="xsd:string"/>
<bpws:variable name="projectName" sca-bpel:hotUpdate="false"
sca-bpel:privateProperty="true" sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ProjectName" type="xsd:string"/>
<bpws:variable name="errorCodeUnexpected"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ErrorCodes/Unexpected" type="xsd:string"/>
<bpws:variable element="ns9:ActivityErrorData"
name="_error_ParseJSON" sca-bpel:internal="true"/>
<bpws:variable element="ns1:logInput"
name="LogMessageConfirmedInfo-input" sca-bpel:internal="true"/>
<bpws:variable name="errorCodeGetSFTPFile"
sca-bpel:hotUpdate="false" sca-bpel:privateProperty="true"
sca-bpel:property="yes"
tibex:propertySource="/A2Mdw/ErrorCodes/GetSFTPFile" type="xsd:string"/>
<bpws:variable element="ns1:logInput"
name="LogMessageReceivedDebug-input" sca-bpel:internal="true"/>
</bpws:variables>
<bpws:extensions>
<bpws:extension mustUnderstand="no" namespace="http://www.eclipse.org/gmf/runtime/1.0.2/notation"/>
<bpws:extension mustUnderstand="no" namespace="http://www.tibco.com/bw/process/info"/>
<bpws:extension mustUnderstand="no" namespace="http://docs.oasis-open.org/ns/opencsa/sca-bpel/200801"/>
<bpws:extension mustUnderstand="no" namespace="http://docs.oasis-open.org/ns/opencsa/sca/200912"/>
<bpws:extension mustUnderstand="no" namespace="http://ns.tibco.com/bw/property"/>
<bpws:extension mustUnderstand="no" namespace="http://www.tibco.com/bpel/2007/extensions"/>
</bpws:extensions>
<bpws:scope name="scope">
<bpws:faultHandlers>
<bpws:catch
faultElement="ns7:KafkaEventSourceFaultException"
faultName="ns7:KafkaEventSourceFaultException"
faultVariable="KafkaEventSourceFaultException" tibex:xpdlId="e7f6d6a0-d437-45df-91aa-fa536422d678">
<bpws:scope name="scope1">
<bpws:flow name="flow1">
<bpws:links/>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogKafkaError-input"
name="LogKafkaError"
tibex:xpdlId="92eaa9ee-74cf-4080-bd46-908e8fdd667a"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&#xa; &lt;xsl:param name=&quot;LogPayloadEnabled&quot;/>&#xa; &lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&#xa; &lt;xsl:param name=&quot;errorCodeKafkaConnection&quot;/>&#xa; &lt;xsl:param name=&quot;_error&quot;/>&#xa; &lt;xsl:param name=&quot;errorCodeKafkaReceiveMessage&quot;/>&#xa; &lt;xsl:template name=&quot;LogErrorKafka-input&quot; match=&quot;/&quot;>&#xa; &lt;tns2:errorReport>&#xa; &lt;tns2:isLastError>&#xa; &lt;xsl:value-of select=&quot;true()&quot;/>&#xa; &lt;/tns2:isLastError>&#xa; &lt;tns2:context>&#xa; &lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&#xa; &lt;/tns2:context>&#xa; &lt;xsl:choose>&#xa; &lt;xsl:when test=&quot;$_error/MsgCode = &amp;quot;500009&amp;quot;&quot;>&#xa; &lt;tns2:logMessage>&#xa; &lt;xsl:value-of select=&quot;&amp;quot;Kafka connection error&amp;quot;&quot;/>&#xa; &lt;/tns2:logMessage>&#xa; &lt;/xsl:when>&#xa; &lt;xsl:otherwise>&#xa; &lt;tns2:logMessage>&#xa; &lt;xsl:value-of select=&quot;&amp;quot;Cannot receive message from Kafka&amp;quot;&quot;/>&#xa; &lt;/tns2:logMessage>&#xa; &lt;/xsl:otherwise>&#xa; &lt;/xsl:choose>&#xa; &lt;xsl:if test=&quot;$LogPayloadEnabled = true()&quot;>&#xa; &lt;tns2:payload>&#xa; &lt;xsl:value-of select=&quot;$KafkaReceiveMessage&quot;/>&#xa; &lt;/tns2:payload>&#xa; &lt;/xsl:if>&#xa; &lt;xsl:choose>&#xa; &lt;xsl:when test=&quot;$_error/MsgCode = &amp;quot;500009&amp;quot;&quot;>&#xa; &lt;tns2:errorId>&#xa; &lt;xsl:value-of select=&quot;concat($projectName, &amp;quot;.APP.&amp;quot;, $errorCodeKafkaConnection)&quot;/>&#xa; &lt;/tns2:errorId>&#xa; &lt;/xsl:when>&#xa; &lt;xsl:otherwise>&#xa; &lt;tns2:errorId>&#xa; &lt;xsl:value-of select=&quot;concat($projectName, &amp;quot;.APP.&amp;quot;, $errorCodeKafkaReceiveMessage)&quot;/>&#xa; &lt;/tns2:errorId>&#xa; &lt;/xsl:otherwise>&#xa; &lt;/xsl:choose>&#xa; &lt;tns2:severity>&#xa; &lt;tns2:severity>&#xa; &lt;xsl:value-of select=&quot;&amp;quot;MINOR&amp;quot;&quot;/>&#xa; &lt;/tns2:severity>&#xa; &lt;/tns2:severity>&#xa; &lt;xsl:if test=&quot;$_error/Data&quot;>&#xa; &lt;tns2:errorDetails>&#xa; &lt;xsl:value-of select=&quot;$_error/Data&quot;/>&#xa; &lt;/tns2:errorDetails>&#xa; &lt;/xsl:if>&#xa; &lt;tns2:tibcoErrorStackType>&#xa; &lt;tns2:processStack>&#xa; &lt;xsl:value-of select=&quot;$_error/ProcessStack&quot;/>&#xa; &lt;/tns2:processStack>&#xa; &lt;tns2:errorMessage>&#xa; &lt;xsl:value-of select=&quot;$_error/Msg&quot;/>&#xa; &lt;/tns2:errorMessage>&#xa; &lt;tns2:errorMessageCode>&#xa; &lt;xsl:value-of select=&quot;$_error/MsgCode&quot;/>&#xa; &lt;/tns2:errorMessageCode>&#xa; &lt;tns2:errorStackTrace>&#xa; &lt;xsl:value-of select=&quot;$_error/StackTrace&quot;/>&#xa; &lt;/tns2:errorStackTrace>&#xa; &lt;tns2:errorClass>&#xa; &lt;xsl:value-of select=&quot;$_error/Class&quot;/>&#xa; &lt;/tns2:errorClass>&#xa; &lt;tns2:errorFullClass>&#xa; &lt;xsl:value-of select=&quot;$_error/FullClass&quot;/>&#xa; &lt;/tns2:errorFullClass>&#xa; &lt;/tns2:tibcoErrorStackType>&#xa; &lt;/tns2:errorReport>&#xa; &lt;/xsl:template>&#xa;&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogError" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
</bpws:flow>
</bpws:scope>
</bpws:catch>
<bpws:catch faultElement="ns8:JSONParserException"
faultName="ns8:JSONParserException"
faultVariable="JSONParserException" tibex:xpdlId="cf0c47db-411e-4f72-bc99-8b1759c779bc">
<bpws:scope name="scope3">
<bpws:flow name="flow3">
<bpws:links>
<bpws:link
name="LogErrorParseJSONToConfirmOnError_1" tibex:linkType="SUCCESS"/>
</bpws:links>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogParseJSONError-input"
name="LogParseJSONError"
tibex:xpdlId="a247c9ff-15c2-4b11-9142-137e283e5a2e"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:sources>
<bpws:source linkName="LogErrorParseJSONToConfirmOnError_1"/>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:tns5=&quot;http://tns.tibco.com/bw/json/1689939614651&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;LogPayloadEnabled&quot;/>&lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&lt;xsl:param name=&quot;_error&quot;/>&lt;xsl:param name=&quot;errorCodeParseJSON&quot;/>&lt;xsl:param name=&quot;projectName&quot;/>&lt;xsl:template name=&quot;LogErrorParseJSON-input&quot; match=&quot;/&quot;>&lt;tns2:errorReport>&lt;tns2:isLastError>&lt;xsl:value-of select=&quot;true()&quot;/>&lt;/tns2:isLastError>&lt;tns2:context>&lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&lt;/tns2:context>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;&amp;quot;Error while parsing received Kafka message&amp;quot;&quot;/>&lt;/tns2:logMessage>&lt;xsl:if test=&quot;$LogPayloadEnabled = true()&quot;>&lt;tns2:payload>&lt;xsl:value-of select=&quot;$KafkaReceiveMessage&quot;/>&lt;/tns2:payload>&lt;/xsl:if>&lt;tns2:errorId>&lt;xsl:value-of select=&quot;concat($projectName, &amp;quot;.APP.&amp;quot;, $errorCodeParseJSON)&quot;/>&lt;/tns2:errorId>&lt;tns2:severity>&lt;tns2:severity>&lt;xsl:value-of select=&quot;&amp;quot;MAJOR&amp;quot;&quot;/>&lt;/tns2:severity>&lt;/tns2:severity>&lt;xsl:if test=&quot;$_error/Data&quot;>&lt;tns2:errorDetails>&lt;xsl:value-of select=&quot;$_error/Data&quot;/>&lt;/tns2:errorDetails>&lt;/xsl:if>&lt;tns2:tibcoErrorStackType>&lt;tns2:processStack>&lt;xsl:value-of select=&quot;$_error/ProcessStack&quot;/>&lt;/tns2:processStack>&lt;tns2:errorMessage>&lt;xsl:value-of select=&quot;$_error/Msg&quot;/>&lt;/tns2:errorMessage>&lt;tns2:errorMessageCode>&lt;xsl:value-of select=&quot;$_error/MsgCode&quot;/>&lt;/tns2:errorMessageCode>&lt;tns2:errorStackTrace>&lt;xsl:value-of select=&quot;$_error/StackTrace&quot;/>&lt;/tns2:errorStackTrace>&lt;tns2:errorClass>&lt;xsl:value-of select=&quot;$_error/Class&quot;/>&lt;/tns2:errorClass>&lt;tns2:errorFullClass>&lt;xsl:value-of select=&quot;$_error/FullClass&quot;/>&lt;/tns2:errorFullClass>&lt;/tns2:tibcoErrorStackType>&lt;/tns2:errorReport>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogError" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:activityExtension
name="ConfirmOnError_1"
tibex:xpdlId="2df3ca56-8b53-4bfb-bc2f-1d115913a7ec" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="LogErrorParseJSONToConfirmOnError_1"/>
</bpws:targets>
<bpws:sources/>
<tibex:config>
<bwext:BWActivity
activityTypeID="bw.generalactivities.confirm"
xmlns:activityconfig="http://tns.tibco.com/bw/model/activityconfig"
xmlns:bwext="http://tns.tibco.com/bw/model/core/bwext"
xmlns:generalactivities="http://ns.tibco.com/bw/palette/generalactivities" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<activityConfig>
<properties name="config" xsi:type="activityconfig:EMFProperty">
<type href="http://ns.tibco.com/bw/palette/generalactivities#//Confirm"/>
<value
confirmEvent="KafkaReceiveMessage" xsi:type="generalactivities:Confirm"/>
</properties>
</activityConfig>
</bwext:BWActivity>
</tibex:config>
</tibex:activityExtension>
</bpws:extensionActivity>
</bpws:flow>
</bpws:scope>
</bpws:catch>
<bpws:catchAll tibex:faultDetailsVar="FaultDetails"
tibex:faultNameVar="FaultName1" tibex:xpdlId="7ebcf1e4-f0bd-4cf6-9c98-c1a405decb1e">
<bpws:scope name="scope2">
<bpws:flow name="flow2">
<bpws:links/>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogProcessingFileError-input"
name="LogProcessingFileError"
tibex:xpdlId="bcbaa52a-57e3-419a-8cf8-06c4be8f6b3f"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:tns5=&quot;http://tns.tibco.com/bw/json/1689939614651&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;FaultDetails&quot;/>&lt;xsl:param name=&quot;LogPayloadEnabled&quot;/>&lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&lt;xsl:param name=&quot;ParseJSON&quot;/>&lt;xsl:param name=&quot;projectName&quot;/>&lt;xsl:param name=&quot;errorCodeUnexpected&quot;/>&lt;xsl:template name=&quot;LogError-input&quot; match=&quot;/&quot;>&lt;tns2:errorReport>&lt;tns2:isLastError>&lt;xsl:value-of select=&quot;true()&quot;/>&lt;/tns2:isLastError>&lt;tns2:context>&lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&lt;/tns2:context>&lt;xsl:choose>&lt;xsl:when test=&quot;string-length($ParseJSON/tns5:fileName) > 0&quot;>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;concat(&amp;quot;Unexpected error while processing: &amp;quot;, $ParseJSON/tns5:fileName)&quot;/>&lt;/tns2:logMessage>&lt;/xsl:when>&lt;xsl:otherwise>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;&amp;quot;Unexpected error while processing unknown file&amp;quot;&quot;/>&lt;/tns2:logMessage>&lt;/xsl:otherwise>&lt;/xsl:choose>&lt;xsl:if test=&quot;$LogPayloadEnabled = true()&quot;>&lt;tns2:payload>&lt;xsl:value-of select=&quot;$KafkaReceiveMessage&quot;/>&lt;/tns2:payload>&lt;/xsl:if>&lt;tns2:errorId>&lt;xsl:value-of select=&quot;concat($projectName, &amp;quot;.APP.&amp;quot;, $errorCodeUnexpected)&quot;/>&lt;/tns2:errorId>&lt;tns2:severity>&lt;tns2:severity>&lt;xsl:value-of select=&quot;&amp;quot;MAJOR&amp;quot;&quot;/>&lt;/tns2:severity>&lt;/tns2:severity>&lt;xsl:if test=&quot;$FaultDetails/Data&quot;>&lt;tns2:errorDetails>&lt;xsl:value-of select=&quot;$FaultDetails/Data&quot;/>&lt;/tns2:errorDetails>&lt;/xsl:if>&lt;tns2:tibcoErrorStackType>&lt;tns2:activityName>&lt;xsl:value-of select=&quot;$FaultDetails/ActivityName&quot;/>&lt;/tns2:activityName>&lt;tns2:processStack>&lt;xsl:value-of select=&quot;$FaultDetails/ProcessStack&quot;/>&lt;/tns2:processStack>&lt;tns2:errorMessage>&lt;xsl:value-of select=&quot;$FaultDetails/Msg&quot;/>&lt;/tns2:errorMessage>&lt;tns2:errorMessageCode>&lt;xsl:value-of select=&quot;$FaultDetails/MsgCode&quot;/>&lt;/tns2:errorMessageCode>&lt;tns2:errorStackTrace>&lt;xsl:value-of select=&quot;$FaultDetails/StackTrace&quot;/>&lt;/tns2:errorStackTrace>&lt;tns2:errorClass>&lt;xsl:value-of select=&quot;$FaultDetails/Class&quot;/>&lt;/tns2:errorClass>&lt;tns2:errorFullClass>&lt;xsl:value-of select=&quot;$FaultDetails/FullClass&quot;/>&lt;/tns2:errorFullClass>&lt;/tns2:tibcoErrorStackType>&lt;/tns2:errorReport>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogError" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
</bpws:flow>
</bpws:scope>
</bpws:catchAll>
</bpws:faultHandlers>
<bpws:flow name="flow">
<bpws:links>
<bpws:link name="KafkaReceiveMessageToGetFile" tibex:linkType="SUCCESSWITHNOCONDITION"/>
<bpws:link name="GetFileToMain" tibex:linkType="SUCCESS"/>
<bpws:link name="ParseJSONToSetInterfaceMetadata" tibex:linkType="SUCCESS"/>
<bpws:link name="GetFileToCopy_1_LogError" tibex:linkType="ERROR"/>
<bpws:link name="SetInterfaceMetadataToLogDebug1" tibex:linkType="SUCCESS"/>
<bpws:link name="LogDebugToGetFile1" tibex:linkType="SUCCESS"/>
<bpws:link name="LogError_1ToCopy_1_ConfirmOnError_1" tibex:linkType="SUCCESS"/>
<bpws:link name="ConfirmToCopy_2_LogInfo" tibex:linkType="SUCCESS"/>
</bpws:links>
<bpws:extensionActivity>
<tibex:receiveEvent createInstance="yes"
eventTimeout="60" name="KafkaReceiveMessage"
tibex:xpdlId="ee17425c-1680-4b0f-a554-45c43c65a549"
variable="KafkaReceiveMessage" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:sources>
<bpws:source linkName="KafkaReceiveMessageToGetFile">
<tibex:DesignExpression>
<tibex:expression
expression="##otherwise##" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"/>
</tibex:DesignExpression>
<bpws:transitionCondition expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"><![CDATA[##otherwise##]]></bpws:transitionCondition>
</bpws:source>
</bpws:sources>
<tibex:eventSource>
<bwext:BWActivity
activityTypeID="bw.kafka.Receiver"
xmlns:activityconfig="http://tns.tibco.com/bw/model/activityconfig"
xmlns:bwext="http://tns.tibco.com/bw/model/core/bwext"
xmlns:kafka="http://ns.tibco.com/bw/palette/kafka" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<attributeBindings
bindingType="moduleProperty"
eAttributeName="groupId" processProperty="consumerGroup"/>
<attributeBindings
bindingType="moduleProperty"
eAttributeName="topicNames" processProperty="topicName"/>
<activityConfig>
<properties name="config" xsi:type="activityconfig:EMFProperty">
<type href="http://ns.tibco.com/bw/palette/kafka#//Receiver"/>
<value autoCommitIntervalMs="5000"
autoOffsetReset="latest"
encodingType="Binary Encoding"
fetchMaxWaitMs="500"
fetchMinBytes="1"
fetchTimeout="1000"
heartbeatIntervalMs="3000"
kafkaConnection="KafkaProperty"
keyDeserializer="String"
maxPartitionFetchBytes="1048576"
sessionTimeoutMs="30000"
useExceptionHandlingDeserializer="true"
valueDeserializer="String" xsi:type="kafka:Receiver"/>
</properties>
</activityConfig>
</bwext:BWActivity>
</tibex:eventSource>
</tibex:receiveEvent>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:extActivity inputVariable="GetFile-input"
name="GetFile" outputVariable="GetFile"
tibex:xpdlId="989964e5-f06f-4c70-9631-1e1055931050"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="LogDebugToGetFile1"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="GetFileToMain"/>
<bpws:source linkName="GetFileToCopy_1_LogError"
tibex:faultDetailsVar="GetFile" tibex:faultNameVar="FaultName">
<tibex:DesignExpression>
<tibex:expression expression="##error##" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"/>
</tibex:DesignExpression>
<bpws:transitionCondition expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xpath2.0"><![CDATA[##error##]]></bpws:transitionCondition>
</bpws:source>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns5=&quot;http://tns.tibco.com/bw/json/1689939614651&quot; xmlns:tns6=&quot;http://lhg.ngmdw.bw.fwk/SFTPGoMFT&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;pathSeparator&quot;/>&lt;xsl:param name=&quot;basePath&quot;/>&lt;xsl:param name=&quot;ParseJSON&quot;/>&lt;xsl:param name=&quot;inputDir&quot;/>&lt;xsl:template name=&quot;GetFile-input&quot; match=&quot;/&quot;>&lt;tns6:GetFileInput>&lt;tns6:fileName>&lt;xsl:value-of select=&quot;$ParseJSON/tns5:filePath&quot;/>&lt;/tns6:fileName>&lt;tns6:useTemporaryFolder>&lt;xsl:value-of select=&quot;true()&quot;/>&lt;/tns6:useTemporaryFolder>&lt;tns6:outputFolder>&lt;xsl:value-of select=&quot;concat($basePath,$pathSeparator,$inputDir)&quot;/>&lt;/tns6:outputFolder>&lt;xsl:if test=&quot;$ParseJSON/tns5:trackingId&quot;>&lt;tns6:trackingId>&lt;xsl:value-of select=&quot;$ParseJSON/tns5:trackingId&quot;/>&lt;/tns6:trackingId>&lt;/xsl:if>&lt;tns6:maxRetries>&lt;xsl:value-of select=&quot;5&quot;/>&lt;/tns6:maxRetries>&lt;tns6:sleepBetweenRetries>&lt;xsl:value-of select=&quot;50&quot;/>&lt;/tns6:sleepBetweenRetries>&lt;/tns6:GetFileInput>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess
moduleRef="lhg-ngmdw-bwce-sm-sftpconnector-gomft"
subProcessName="lhg.ngmdw.bw.sftp.gomft.GetFile" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:activityExtension inputVariable="ParseJSON-input"
name="ParseJSON" outputVariable="ParseJSON"
tibex:xpdlId="24799963-9589-4f7b-a810-086f3463bcc0" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="KafkaReceiveMessageToGetFile"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="ParseJSONToSetInterfaceMetadata"/>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns4=&quot;activity.jsonParser.input+____UUID____+ActivityInputType&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&lt;xsl:template name=&quot;ParseJSON-input&quot; match=&quot;/&quot;>&lt;ns0:ActivityInputClass xmlns:ns0=&quot;activity.jsonParser.input+24799963-9589-4f7b-a810-086f3463bcc0+ActivityInputType&quot;>&lt;jsonString>&lt;xsl:value-of select=&quot;$KafkaReceiveMessage/message&quot;/>&lt;/jsonString>&lt;/ns0:ActivityInputClass>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:config>
<bwext:BWActivity
activityTypeID="bw.restjson.JsonParser"
xmlns:activityconfig="http://tns.tibco.com/bw/model/activityconfig"
xmlns:bwext="http://tns.tibco.com/bw/model/core/bwext"
xmlns:restjson="http://ns.tibco.com/bw/palette/restjson" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<activityConfig>
<properties name="config" xsi:type="activityconfig:EMFProperty">
<type href="http://ns.tibco.com/bw/palette/restjson#//JsonParser"/>
<value jsonInputStyle="None"
schemaType="Xsd" xsi:type="restjson:JsonParser">
<outputEditorElement href="platform:/resource/ttt55.module/Schemas/FileDispatcherInputResource.xsd#//FileDispatcherInputElement;XSDElementDeclaration"/>
</value>
</properties>
</activityConfig>
</bwext:BWActivity>
</tibex:config>
</tibex:activityExtension>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:activityExtension name="Confirm"
tibex:xpdlId="7903f618-ca89-4f6c-a8cd-a7db439c8f9e" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="GetFileToMain"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="ConfirmToCopy_2_LogInfo"/>
</bpws:sources>
<tibex:config>
<bwext:BWActivity
activityTypeID="bw.generalactivities.confirm"
xmlns:activityconfig="http://tns.tibco.com/bw/model/activityconfig"
xmlns:bwext="http://tns.tibco.com/bw/model/core/bwext"
xmlns:generalactivities="http://ns.tibco.com/bw/palette/generalactivities" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<activityConfig>
<properties name="config" xsi:type="activityconfig:EMFProperty">
<type href="http://ns.tibco.com/bw/palette/generalactivities#//Confirm"/>
<value
confirmEvent="KafkaReceiveMessage" xsi:type="generalactivities:Confirm"/>
</properties>
</activityConfig>
</bwext:BWActivity>
</tibex:config>
</tibex:activityExtension>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogSFTPGetFileError-input"
name="LogSFTPGetFileError"
tibex:xpdlId="328af84f-7f13-47d8-bbaa-df838a4294fc"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="GetFileToCopy_1_LogError"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="LogError_1ToCopy_1_ConfirmOnError_1"/>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:tns5=&quot;http://tns.tibco.com/bw/json/1689939614651&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;LogPayloadEnabled&quot;/>&lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&lt;xsl:param name=&quot;ParseJSON&quot;/>&lt;xsl:param name=&quot;_error&quot;/>&lt;xsl:param name=&quot;projectName&quot;/>&lt;xsl:param name=&quot;errorCodeGetSFTPFile&quot;/>&lt;xsl:template name=&quot;LogError_1-input&quot; match=&quot;/&quot;>&lt;tns2:errorReport>&lt;tns2:isLastError>&lt;xsl:value-of select=&quot;true()&quot;/>&lt;/tns2:isLastError>&lt;tns2:context>&lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&lt;/tns2:context>&lt;xsl:choose>&lt;xsl:when test=&quot;string-length($ParseJSON/tns5:fileName) > 0&quot;>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;concat(&amp;quot;Error while getting file from SFTP: &amp;quot;, $ParseJSON/tns5:fileName)&quot;/>&lt;/tns2:logMessage>&lt;/xsl:when>&lt;xsl:otherwise>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;&amp;quot;Error while getting file from SFTP&amp;quot;&quot;/>&lt;/tns2:logMessage>&lt;/xsl:otherwise>&lt;/xsl:choose>&lt;xsl:if test=&quot;$LogPayloadEnabled = true()&quot;>&lt;tns2:payload>&lt;xsl:value-of select=&quot;$KafkaReceiveMessage&quot;/>&lt;/tns2:payload>&lt;/xsl:if>&lt;tns2:errorId>&lt;xsl:value-of select=&quot;concat($projectName, &amp;quot;.APP.&amp;quot;, $errorCodeGetSFTPFile)&quot;/>&lt;/tns2:errorId>&lt;tns2:severity>&lt;tns2:severity>&lt;xsl:value-of select=&quot;&amp;quot;MAJOR&amp;quot;&quot;/>&lt;/tns2:severity>&lt;/tns2:severity>&lt;tns2:tibcoErrorStackType>&lt;tns2:processStack>&lt;xsl:value-of select=&quot;$_error/ProcessStack&quot;/>&lt;/tns2:processStack>&lt;tns2:errorMessage>&lt;xsl:value-of select=&quot;$_error/Msg&quot;/>&lt;/tns2:errorMessage>&lt;tns2:errorMessageCode>&lt;xsl:value-of select=&quot;$_error/MsgCode&quot;/>&lt;/tns2:errorMessageCode>&lt;tns2:errorStackTrace>&lt;xsl:value-of select=&quot;$_error/StackTrace&quot;/>&lt;/tns2:errorStackTrace>&lt;tns2:errorClass>&lt;xsl:value-of select=&quot;$_error/Class&quot;/>&lt;/tns2:errorClass>&lt;tns2:errorFullClass>&lt;xsl:value-of select=&quot;$_error/FullClass&quot;/>&lt;/tns2:errorFullClass>&lt;/tns2:tibcoErrorStackType>&lt;/tns2:errorReport>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogError" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="SetInterfaceMetadata-input"
name="SetInterfaceMetadata"
tibex:xpdlId="bddcfc15-99fd-4efa-aacd-23fcaee56b3d"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="ParseJSONToSetInterfaceMetadata"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="SetInterfaceMetadataToLogDebug1"/>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns5=&quot;http://tns.tibco.com/bw/json/1689939614651&quot; xmlns:tns1=&quot;http://www.onemdw.org/MainSchema&quot; xmlns:tib=&quot;http://www.tibco.com/bw/xslt/custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;ParseJSON&quot;/>&lt;xsl:param name=&quot;InterfaceName&quot;/>&lt;xsl:param name=&quot;basePath&quot;/>&lt;xsl:param name=&quot;maxRetry&quot;/>&lt;xsl:param name=&quot;continueOnError&quot;/>&lt;xsl:param name=&quot;retryTimeInSeconds&quot;/>&lt;xsl:param name=&quot;isCustomPreAction&quot;/>&lt;xsl:param name=&quot;isCustomPreDeliver&quot;/>&lt;xsl:param name=&quot;isCustomPostAction&quot;/>&lt;xsl:param name=&quot;isCustomErrorHandling&quot;/>&lt;xsl:template name=&quot;SetInterfaceMetadata-input&quot; match=&quot;/&quot;>&lt;tns1:initInput>&lt;tns1:messageId>&lt;xsl:value-of select=&quot;tib:uuid()&quot;/>&lt;/tns1:messageId>&lt;xsl:if test=&quot;$ParseJSON/tns5:trackingId&quot;>&lt;tns1:trackingId>&lt;xsl:value-of select=&quot;$ParseJSON/tns5:trackingId&quot;/>&lt;/tns1:trackingId>&lt;/xsl:if>&lt;tns1:interfaceName>&lt;xsl:value-of select=&quot;$InterfaceName&quot;/>&lt;/tns1:interfaceName>&lt;tns1:fullFilename>&lt;xsl:value-of select=&quot;$ParseJSON/tns5:fileName&quot;/>&lt;/tns1:fullFilename>&lt;tns1:sourceSystem>&lt;xsl:value-of select=&quot;&amp;quot;ALTEA&amp;quot;&quot;/>&lt;/tns1:sourceSystem>&lt;tns1:targetSystem>&lt;xsl:value-of select=&quot;&amp;quot;MDW&amp;quot;&quot;/>&lt;/tns1:targetSystem>&lt;tns1:interfaceConfig>&lt;tns1:basePath>&lt;xsl:value-of select=&quot;$basePath&quot;/>&lt;/tns1:basePath>&lt;tns1:deliverConfig>&lt;tns1:maxRetry>&lt;xsl:value-of select=&quot;$maxRetry&quot;/>&lt;/tns1:maxRetry>&lt;tns1:continueOnError>&lt;xsl:value-of select=&quot;$continueOnError&quot;/>&lt;/tns1:continueOnError>&lt;tns1:isOnlyOneOutputFile>&lt;xsl:value-of select=&quot;false()&quot;/>&lt;/tns1:isOnlyOneOutputFile>&lt;tns1:retryTimeInSeconds>&lt;xsl:value-of select=&quot;$retryTimeInSeconds&quot;/>&lt;/tns1:retryTimeInSeconds>&lt;/tns1:deliverConfig>&lt;tns1:extensionsConfig>&lt;tns1:isCustomPreAction>&lt;xsl:value-of select=&quot;$isCustomPreAction&quot;/>&lt;/tns1:isCustomPreAction>&lt;tns1:isCustomPreDeliver>&lt;xsl:value-of select=&quot;$isCustomPreDeliver&quot;/>&lt;/tns1:isCustomPreDeliver>&lt;tns1:isCustomPostAction>&lt;xsl:value-of select=&quot;$isCustomPostAction&quot;/>&lt;/tns1:isCustomPostAction>&lt;tns1:isCustomErrorHandling>&lt;xsl:value-of select=&quot;$isCustomErrorHandling&quot;/>&lt;/tns1:isCustomErrorHandling>&lt;/tns1:extensionsConfig>&lt;/tns1:interfaceConfig>&lt;/tns1:initInput>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.utils.SetInterfaceMetadata" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:activityExtension name="_ConfirmOnError_1"
tibex:xpdlId="9f899c6c-5c45-4994-92fc-193c28acc46a" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="LogError_1ToCopy_1_ConfirmOnError_1"/>
</bpws:targets>
<bpws:sources/>
<tibex:config>
<bwext:BWActivity
activityTypeID="bw.generalactivities.confirm"
xmlns:activityconfig="http://tns.tibco.com/bw/model/activityconfig"
xmlns:bwext="http://tns.tibco.com/bw/model/core/bwext"
xmlns:generalactivities="http://ns.tibco.com/bw/palette/generalactivities" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<activityConfig>
<properties name="config" xsi:type="activityconfig:EMFProperty">
<type href="http://ns.tibco.com/bw/palette/generalactivities#//Confirm"/>
<value
confirmEvent="KafkaReceiveMessage" xsi:type="generalactivities:Confirm"/>
</properties>
</activityConfig>
</bwext:BWActivity>
</tibex:config>
</tibex:activityExtension>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogMessageConfirmedInfo-input"
name="LogMessageConfirmedInfo"
tibex:xpdlId="a788154f-e51c-452a-b172-07227819c6df"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="ConfirmToCopy_2_LogInfo"/>
</bpws:targets>
<bpws:sources/>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:template name=&quot;Copy_2_LogInfo-input&quot; match=&quot;/&quot;>&lt;tns2:logInput>&lt;tns2:commonLog>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;&amp;quot;Confirmed message from Kafka&amp;quot;&quot;/>&lt;/tns2:logMessage>&lt;tns2:context>&lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&lt;/tns2:context>&lt;/tns2:commonLog>&lt;/tns2:logInput>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogInfo" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
<bpws:extensionActivity>
<tibex:extActivity
inputVariable="LogMessageReceivedDebug-input"
name="LogMessageReceivedDebug"
tibex:xpdlId="4d5eb1bc-94e9-4c3a-bce4-bafcef4eda02"
type="bw.generalactivities.callprocess" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions">
<bpws:targets>
<bpws:target linkName="SetInterfaceMetadataToLogDebug1"/>
</bpws:targets>
<bpws:sources>
<bpws:source linkName="LogDebugToGetFile1"/>
</bpws:sources>
<tibex:inputBindings>
<tibex:inputBinding coercion=""
expression="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot;?>&#xa;&lt;xsl:stylesheet xmlns:xsl=&quot;http://www.w3.org/1999/XSL/Transform&quot; xmlns:tns2=&quot;http://www.onemdw.org/SimpleMonitor&quot; xmlns:bw=&quot;http://www.tibco.com/bw/xpath/bw-custom-functions&quot; version=&quot;2.0&quot;>&lt;xsl:param name=&quot;KafkaReceiveMessage&quot;/>&lt;xsl:template name=&quot;LogMessageReceivedDebug-input&quot; match=&quot;/&quot;>&lt;tns2:logInput>&lt;tns2:commonLog>&lt;tns2:logMessage>&lt;xsl:value-of select=&quot;concat(&amp;quot;Received message from Kafka with payload: &amp;quot;, $KafkaReceiveMessage/message)&quot;/>&lt;/tns2:logMessage>&lt;tns2:context>&lt;xsl:value-of select=&quot;bw:getModuleProperty(&amp;quot;BW.PROCESS.NAME&amp;quot;)&quot;/>&lt;/tns2:context>&lt;/tns2:commonLog>&lt;/tns2:logInput>&lt;/xsl:template>&lt;/xsl:stylesheet>" expressionLanguage="urn:oasis:names:tc:wsbpel:2.0:sublang:xslt1.0"/>
</tibex:inputBindings>
<tibex:CallProcess moduleRef="bwce-fwk"
subProcessName="onemdw.bwce.fwk.log.LogDebug" xmlns:tibex="http://www.tibco.com/bpel/2007/extensions"/>
</tibex:extActivity>
</bpws:extensionActivity>
</bpws:flow>
</bpws:scope>
</bpws:process>
Reference in New Issue View Git Blame Copy Permalink