Menu
▾
▴
[Cse-ip-svn-commits] SF.net SVN: cse-ip:[242] trunk/sandbox/lsf-adapter-demo/ILIASClientAdapter/ src/OutboundClientAdapter.bpel
|
From: <pka...@us...> - 2009-06-09 07:41:20
|
Revision: 242
http://cse-ip.svn.sourceforge.net/cse-ip/?rev=242&view=rev
Author: pkasprzak
Date: 2009-06-09 07:41:17 +0000 (Tue, 09 Jun 2009)
Log Message:
-----------
* Generate replies
Modified Paths:
--------------
trunk/sandbox/lsf-adapter-demo/ILIASClientAdapter/src/OutboundClientAdapter.bpel
Modified: trunk/sandbox/lsf-adapter-demo/ILIASClientAdapter/src/OutboundClientAdapter.bpel
===================================================================
--- trunk/sandbox/lsf-adapter-demo/ILIASClientAdapter/src/OutboundClientAdapter.bpel 2009-06-09 07:39:56 UTC (rev 241)
+++ trunk/sandbox/lsf-adapter-demo/ILIASClientAdapter/src/OutboundClientAdapter.bpel 2009-06-09 07:41:17 UTC (rev 242)
@@ -7,6 +7,7 @@
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:sxed2="http://www.sun.com/wsbpel/2.0/process/executable/SUNExtension/Editor2"
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"
@@ -87,6 +88,9 @@
<variable name="ObjectClientId" type="xsd:string"/>
<variable name="ReplyStatus" type="dt:statusType"/>
+ <!-- For testing -->
+ <variable name="ReplyXML" type="xsd:string"/>
+
</variables>
<sequence>
@@ -114,11 +118,11 @@
<to variable="SID"/>
</copy>
<copy>
- <from>$ProcessCourseOperationIn.courseMessage/course/busId</from>
+ <from>$ProcessCourseOperationIn.courseMessage/dt:course/dt:busId</from>
<to>$ObjectBusId</to>
</copy>
<copy ignoreMissingFromData="yes">
- <from>$ProcessCourseOperationIn.courseMessage/course/attribute[name = 'clientId']/value</from>
+ <from>$ProcessCourseOperationIn.courseMessage/dt:course/dt:attribute[dt:name = 'clientId']/dt:value</from>
<to>$ObjectClientId</to>
</copy>
<!-- Init constants (better alternatives?) -->
@@ -136,12 +140,12 @@
<if>
<sxt:trace>
<sxt:log level="info" location="onStart">
- <from>concat('*** Branching on course-event: ', $ProcessCourseOperationIn.courseMessage/event)</from>
+ <from>concat('*** Branching on course-event: ', $ProcessCourseOperationIn.courseMessage/dt:event)</from>
</sxt:log>
</sxt:trace>
<!-- Event == "CREATE" -->
- <condition>$ProcessCourseOperationIn.courseMessage/event = 'CREATE'</condition>
+ <condition>$ProcessCourseOperationIn.courseMessage/dt:event = 'CREATE'</condition>
<sequence>
<assign name="prepareAddCourse">
<sxt:trace>
@@ -150,7 +154,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCourseOperationIn.courseMessage/course</from>
+ <from>$ProcessCourseOperationIn.courseMessage/dt:course</from>
<to>$AddCourseIn.course</to>
</copy>
<copy>
@@ -193,7 +197,7 @@
</sequence>
<elseif>
<!-- Event == "UPDATE" -->
- <condition>$ProcessCourseOperationIn.courseMessage/event = 'UPDATE'</condition>
+ <condition>$ProcessCourseOperationIn.courseMessage/dt:event = 'UPDATE'</condition>
<sequence>
<assign name="prepareUpdateCourse">
<sxt:trace>
@@ -202,7 +206,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCourseOperationIn.courseMessage/course</from>
+ <from>$ProcessCourseOperationIn.courseMessage/dt:course</from>
<to>$UpdateCourseIn.course</to>
</copy>
<copy>
@@ -238,7 +242,7 @@
</elseif>
<elseif>
<!-- Event == "DELETE" -->
- <condition>$ProcessCourseOperationIn.courseMessage/event = 'DELETE'</condition>
+ <condition>$ProcessCourseOperationIn.courseMessage/dt:event = 'DELETE'</condition>
<sequence>
<assign name="prepareDeleteCourse">
<sxt:trace>
@@ -247,7 +251,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCourseOperationIn.courseMessage/course</from>
+ <from>$ProcessCourseOperationIn.courseMessage/dt:course</from>
<to>$DeleteCourseIn.course</to>
</copy>
<copy>
@@ -318,11 +322,11 @@
<to variable="SID"/>
</copy>
<copy>
- <from>$ProcessCategoryOperationIn.categoryMessage/category/busId</from>
+ <from>$ProcessCategoryOperationIn.categoryMessage/dt:category/dt:busId</from>
<to>$ObjectBusId</to>
</copy>
<copy ignoreMissingFromData="yes">
- <from>$ProcessCategoryOperationIn.categoryMessage/category/attribute[name = 'clientId']/value</from>
+ <from>$ProcessCategoryOperationIn.categoryMessage/dt:category/dt:attribute[dt:name = 'clientId']/dt:value</from>
<to>$ObjectClientId</to>
</copy>
<!-- Init constants (better alternatives?) -->
@@ -340,12 +344,12 @@
<if>
<sxt:trace>
<sxt:log level="info" location="onStart">
- <from>concat('*** Branching on category-event: ', $ProcessCategoryOperationIn.categoryMessage/event)</from>
+ <from>concat('*** Branching on category-event: ', $ProcessCategoryOperationIn.categoryMessage/dt:event)</from>
</sxt:log>
</sxt:trace>
<!-- Event == "CREATE" -->
- <condition>$ProcessCategoryOperationIn.categoryMessage/event = 'CREATE'</condition>
+ <condition>$ProcessCategoryOperationIn.categoryMessage/dt:event = 'CREATE'</condition>
<sequence>
<assign name="prepareAddCategory">
<sxt:trace>
@@ -354,7 +358,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCategoryOperationIn.categoryMessage/category</from>
+ <from>$ProcessCategoryOperationIn.categoryMessage/dt:category</from>
<to>$AddCategoryIn.category</to>
</copy>
<copy>
@@ -395,7 +399,7 @@
</sequence>
<elseif>
<!-- Event == "UPDATE" -->
- <condition>$ProcessCategoryOperationIn.categoryMessage/event = 'UPDATE'</condition>
+ <condition>$ProcessCategoryOperationIn.categoryMessage/dt:event = 'UPDATE'</condition>
<sequence>
<assign name="prepareUpdateCategory">
<sxt:trace>
@@ -404,7 +408,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCategoryOperationIn.categoryMessage/category</from>
+ <from>$ProcessCategoryOperationIn.categoryMessage/dt:category</from>
<to>$UpdateCategoryIn.category</to>
</copy>
<copy>
@@ -441,7 +445,7 @@
</elseif>
<elseif>
<!-- Event == "DELETE" -->
- <condition>$ProcessCategoryOperationIn.categoryMessage/event = 'DELETE'</condition>
+ <condition>$ProcessCategoryOperationIn.categoryMessage/dt:event = 'DELETE'</condition>
<sequence>
<assign name="prepareDeleteCategory">
<sxt:trace>
@@ -450,7 +454,7 @@
</sxt:log>
</sxt:trace>
<copy>
- <from>$ProcessCategoryOperationIn.categoryMessage/category</from>
+ <from>$ProcessCategoryOperationIn.categoryMessage/dt:category</from>
<to>$DeleteCategoryIn.category</to>
</copy>
<copy>
@@ -520,53 +524,56 @@
<!-- Generate reply(s) -->
<assign name="prepareReply">
- <sxt:trace>
- <sxt:log level="info" location="onComplete">
- <from>concat('*** Reply: ', $ProcessReplyIn.reply, 'END')</from>
- </sxt:log>
- </sxt:trace>
<copy>
<from>
<literal>
- <reply xmlns="http://cse.campussource.de/schema/DataTypes">
- <objectBusId/>
- <objectClientId/>
+ <eventReplyMessage xmlns="http://cse.campussource.de/schema/DataTypes">
+ <objectBusId>4</objectBusId>
+ <objectClientId>client5</objectClientId>
<replyTime/>
- <replyStatus/>
+ <replyStatus>SUCCESS</replyStatus>
<info/>
- </reply>
+ </eventReplyMessage>
</literal>
</from>
- <to>$ProcessReplyIn.reply</to>
+ <to>$ProcessReplyIn.eventReply</to>
</copy>
</assign>
-<!--
<assign>
<copy>
- <from>$ObjectBusId</from>
- <to>$ProcessReplyIn.reply/objectBusId</to>
+ <from variable="ObjectBusId"/>
+ <to>$ProcessReplyIn.eventReply/dt:objectBusId</to>
</copy>
-
<copy>
- <from>$ObjectClientId</from>
- <to>$ProcessReplyIn.reply/objectClientId</to>
+ <from variable="ObjectClientId"/>
+ <to>$ProcessReplyIn.eventReply/dt:objectClientId</to>
</copy>
<copy>
- <from>$ReplyStatus</from>
- <to>$ProcessReplyIn.reply/replyStatus</to>
+ <from variable="ReplyStatus"/>
+ <to>$ProcessReplyIn.eventReply/dt:replyStatus</to>
</copy>
<copy>
- <from>sxxf:current-time()</from>
- <to>$ProcessReplyIn.reply/replyTime</to>
+ <from>sxxf:current-dateTime()</from>
+ <to>$ProcessReplyIn.eventReply/dt:replyTime</to>
</copy>
+ </assign>
+ <assign name="debugReply">
+ <sxt:trace>
+ <sxt:log level="info" location="onComplete">
+ <from>concat('*** Reply: ', $ReplyXML, 'END')</from>
+ </sxt:log>
+ </sxt:trace>
+ <copy>
+ <from>sxxf:doMarshal($ProcessReplyIn.eventReply)</from>
+ <to>$ReplyXML</to>
+ </copy>
</assign>
<invoke name="returnReply" partnerLink="ReplyProcessor" operation="processReply"
xmlns:tns="http://j2ee.netbeans.org/wsdl/ObjectProcessor/ReplyProcessor"
portType="tns:ReplyProcessorPortType"
inputVariable="ProcessReplyIn"/>
--->
</sequence>
</process>
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
