From: <pka...@us...> - 2009-07-03 13:08:22
|
Revision: 308 http://cse-ip.svn.sourceforge.net/cse-ip/?rev=308&view=rev Author: pkasprzak Date: 2009-07-03 12:46:21 +0000 (Fri, 03 Jul 2009) Log Message: ----------- * ClientIds / ClientInstanceIds are now part of messages * Renameing / restructuring / cleanups Modified Paths: -------------- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.bpel trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.wsdl Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.bpel =================================================================== --- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.bpel 2009-07-03 12:43:09 UTC (rev 307) +++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.bpel 2009-07-03 12:46:21 UTC (rev 308) @@ -1,78 +1,92 @@ <?xml version="1.0" encoding="UTF-8"?> -<process - name="InboundObjectProcessor" - targetNamespace="http://enterprise.netbeans.org/bpel/ObjectProcessor/newProcess" - xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable" - xmlns:xsd="http://www.w3.org/2001/XMLSchema" - xmlns:sxt="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Trace" - xmlns:sxed="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor" - xmlns:sxat="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Attachment" - xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling" - xmlns:sxxf="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/XPathFunctions" - xmlns:ns0="http://docs.oasis-open.org/wsbpel/2.0/process/executable" - xmlns:tns="http://enterprise.netbeans.org/bpel/ObjectProcessor/newProcess"> +<process name="InboundObjectProcessor" + targetNamespace="http://enterprise.netbeans.org/bpel/ObjectProcessor/newProcess" + xmlns="http://docs.oasis-open.org/wsbpel/2.0/process/executable" + xmlns:xsd="http://www.w3.org/2001/XMLSchema" + xmlns:sxt="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Trace" + xmlns:sxed="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor" + xmlns:sxat="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Attachment" + xmlns:sxeh="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/ErrorHandling" + xmlns:sxxf="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/XPathFunctions" + xmlns:ns0="http://docs.oasis-open.org/wsbpel/2.0/process/executable" + xmlns:dt="http://cse.campussource.de/schema/DataTypes" + xmlns:tns="http://enterprise.netbeans.org/bpel/ObjectProcessor/newProcess"> <import namespace="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" location="InboundObjectProcessor.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/> <import namespace="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" location="IdentityMapper/wsdl/IdentityMapperWS/IdentityMapper.wsdl" importType="http://schemas.xmlsoap.org/wsdl/"/> + <import namespace="http://cse.campussource.de/schema/DataTypes" location="Common/CDDM.xsd" importType="http://www.w3.org/2001/XMLSchema"/> + <partnerLinks> <partnerLink name="IdentityMapper" xmlns:tns="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" partnerLinkType="tns:IdentityMapper" partnerRole="IdentityMapperPortTypeRole"/> + <partnerLink name="ClientAdapter" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" partnerLinkType="tns:ObjectProcessor" myRole="ObjectProcessorPortTypeRole"/> </partnerLinks> + <variables> - <variable name="ProcessCategoryOperationIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" messageType="tns:ProcessCategoryOperationRequest"/> - <variable name="ProcessCourseOperationIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" messageType="tns:ProcessCourseOperationRequest"/> - <variable name="ToBusIdOperationOut" xmlns:tns="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" messageType="tns:ToBusIdOperationResponse"/> - <variable name="ToBusIdOperationIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" messageType="tns:ToBusIdOperationRequest"/> + <variable name="ProcessCategoryEventIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" messageType="tns:ProcessCategoryEventRequest"/> + <variable name="ProcessCourseEventIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" messageType="tns:ProcessCourseEventRequest"/> + + <variable name="ToBusIdOperationOut" xmlns:tns="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" messageType="tns:ToBusIdOperationResponse"/> + <variable name="ToBusIdOperationIn" xmlns:tns="http://j2ee.netbeans.org/wsdl/IdentityMapper/IdentityMapper" messageType="tns:ToBusIdOperationRequest"/> </variables> + <sequence> <pick name="receiveObject" createInstance="yes"> - <onMessage partnerLink="ClientAdapter" - operation="ProcessCourseOperation" - xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" - portType="tns:ObjectProcessorPortType" - variable="ProcessCourseOperationIn"> + <onMessage partnerLink="ClientAdapter" operation="processCourseEvent" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" + portType="tns:ObjectProcessorPortType" + variable="ProcessCourseEventIn"> <sequence> <assign name="prepareResolveBusIdForCourse"> <sxt:trace> <sxt:log level="info" location="onStart"> - <ns0:from>concat('*** Course: ', sxxf:doMarshal($ProcessCourseOperationIn.courseMessage))</ns0:from> + <ns0:from>concat('*** Course: ', sxxf:doMarshal($ProcessCourseEventIn.courseMessage))</ns0:from> </sxt:log> </sxt:trace> +<!-- <copy> - <from variable="ProcessCourseOperationIn" part="clientInstanceId"/> - <to variable="ToBusIdOperationIn" part="clientInstanceId"/> + <from>$ProcessCourseEventIn.courseMessage/dt:source</from> + <to>$ToBusIdOperationIn.clientInstanceId</to> </copy> +--> <copy> - <from variable="ProcessCourseOperationIn" part="clientObjectId"/> - <to variable="ToBusIdOperationIn" part="clientObjectId"/> + <from>1</from> + <to>$ToBusIdOperationIn.clientInstanceId</to> </copy> + <copy> + <from>$ProcessCourseEventIn.courseMessage/dt:course/dt:attribute[dt:name = 'clientId']/dt:value</from> + <to>$ToBusIdOperationIn.clientObjectId</to> + </copy> </assign> </sequence> </onMessage> - <onMessage partnerLink="ClientAdapter" - operation="ProcessCategoryOperation" - xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" - portType="tns:ObjectProcessorPortType" - variable="ProcessCategoryOperationIn"> + <onMessage partnerLink="ClientAdapter" operation="processCategoryEvent" xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ObjectProcessor" + portType="tns:ObjectProcessorPortType" + variable="ProcessCategoryEventIn"> <sequence> <assign name="prepareResolveBusIdForCategory"> <sxt:trace> <sxt:log level="info" location="onStart"> - <ns0:from>concat('*** Category: ', sxxf:doMarshal($ProcessCategoryOperationIn.categoryMessage))</ns0:from> + <ns0:from>concat('*** Category: ', sxxf:doMarshal($ProcessCategoryEventIn.categoryMessage))</ns0:from> </sxt:log> </sxt:trace> +<!-- <copy> - <from variable="ProcessCategoryOperationIn" part="clientInstanceId"/> - <to variable="ToBusIdOperationIn" part="clientInstanceId"/> + <from>$ProcessCategoryEventIn.categoryMessage/dt:source</from> + <to>$ToBusIdOperationIn.clientInstanceId</to> </copy> +--> <copy> - <from variable="ProcessCategoryOperationIn" part="clientObjectId"/> - <to variable="ToBusIdOperationIn" part="clientObjectId"/> + <from>1</from> + <to>$ToBusIdOperationIn.clientInstanceId</to> </copy> + <copy> + <from>$ProcessCategoryEventIn.categoryMessage/dt:category/dt:attribute[dt:name = 'clientId']/dt:value</from> + <to>$ToBusIdOperationIn.clientObjectId</to> + </copy> </assign> </sequence> </onMessage> Modified: trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.wsdl =================================================================== --- trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.wsdl 2009-07-03 12:43:09 UTC (rev 307) +++ trunk/sandbox/lsf-adapter-demo/ObjectProcessor/src/InboundObjectProcessor.wsdl 2009-07-03 12:46:21 UTC (rev 308) @@ -11,38 +11,46 @@ <xsd:import namespace="http://cse.campussource.de/schema/DataTypes" schemaLocation="Common/CDDM.xsd"/> </xsd:schema> </types> - <message name="ProcessCourseOperationRequest"> - <part name="clientInstanceId" type="xsd:long"/> - <part name="clientObjectId" type="xsd:string"/> + <message name="ProcessCourseEventRequest"> <part name="courseMessage" type="dt:courseMessageType"/> </message> - <message name="ProcessCategoryOperationRequest"> - <part name="clientInstanceId" type="xsd:long"/> - <part name="clientObjectId" type="xsd:string"/> + <message name="ProcessCategoryEventRequest"> <part name="categoryMessage" type="dt:categoryMessageType"/> </message> + <message name="ProcessAccountEventRequest"> + <part name="accountMessage" type="dt:accountMessageType"/> + </message> <portType name="ObjectProcessorPortType"> - <operation name="ProcessCourseOperation"> - <input name="input1" message="tns:ProcessCourseOperationRequest"/> + <operation name="processCourseEvent"> + <input name="input1" message="tns:ProcessCourseEventRequest"/> </operation> - <operation name="ProcessCategoryOperation"> - <input name="input2" message="tns:ProcessCategoryOperationRequest"/> + <operation name="processCategoryEvent"> + <input name="input2" message="tns:ProcessCategoryEventRequest"/> </operation> + <operation name="processAccountEvent"> + <input name="input3" message="tns:ProcessAccountEventRequest"/> + </operation> </portType> <binding name="ObjectProcessorPortTypeBinding" type="tns:ObjectProcessorPortType"> <soap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/> - <operation name="ProcessCourseOperation"> + <operation name="processCourseEvent"> <soap:operation/> <input name="input1"> <soap:body use="literal"/> </input> </operation> - <operation name="ProcessCategoryOperation"> + <operation name="processCategoryEvent"> <soap:operation/> <input name="input2"> <soap:body use="literal"/> </input> </operation> + <operation name="processAccountEvent"> + <soap:operation/> + <input name="input3"> + <soap:body use="literal"/> + </input> + </operation> </binding> <service name="ObjectProcessorService"> <port name="ObjectProcessorPortTypeBindingPort" binding="tns:ObjectProcessorPortTypeBinding"> This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |