[Cse-ip-svn-commits] SF.net SVN: cse-ip:[311] trunk/sandbox/lsf-adapter-demo/LSFClientAdapter/ src/InboundClientAdapter.bpel

[<pka...@us...>]

Revision: 311
          http://cse-ip.svn.sourceforge.net/cse-ip/?rev=311&view=rev
Author:   pkasprzak
Date:     2009-07-03 14:33:16 +0000 (Fri, 03 Jul 2009)

Log Message:
-----------
* Support for account / accountMessage in LSFAdapter / ObjectProcessor
* Added preliminary version of IliasAdapter:AddAccount.bpel

Modified Paths:
--------------
    trunk/sandbox/lsf-adapter-demo/LSFClientAdapter/src/InboundClientAdapter.bpel

Modified: trunk/sandbox/lsf-adapter-demo/LSFClientAdapter/src/InboundClientAdapter.bpel
===================================================================
--- trunk/sandbox/lsf-adapter-demo/LSFClientAdapter/src/InboundClientAdapter.bpel	2009-07-03 14:33:10 UTC (rev 310)
+++ trunk/sandbox/lsf-adapter-demo/LSFClientAdapter/src/InboundClientAdapter.bpel	2009-07-03 14:33:16 UTC (rev 311)
@@ -134,7 +134,7 @@
                         </copy>
                     </assign>
 
-                    <!-- Init courseMessage -->
+                    <!-- Update courseMessage -->
                     <assign name="updateCourseMessage">
                         <copy>
                             <from>string($SOURCE_SYSTEM_ID)</from>
@@ -185,7 +185,7 @@
                         </copy>
                     </assign>
 
-                    <!-- Init categoryMessage -->
+                    <!-- Update categoryMessage -->
                     <assign name="updateCategoryMessage">
                         <copy>
                             <from>string($SOURCE_SYSTEM_ID)</from>
@@ -205,5 +205,57 @@
             </scope>
         </forEach>
 
+        <!-- Convert CSE:account -> CDDM:accountMessage -->
+        <forEach name="AccountSplitter" parallel="no" counterName="AccountCounter">
+
+            <sxt:trace>
+                <sxt:log level="info" location="onStart">
+                    <ns0:from>'*** AccountSplitter start'</ns0:from>
+                </sxt:log>
+            </sxt:trace>
+
+            <startCounterValue>1</startCounterValue>
+            <finalCounterValue>count($Messages/dt:accountMessages/*)</finalCounterValue>
+
+            <scope name="invokeObjectProcessorForAccountMessages">
+                <variables>
+                    <variable name="ProcessAccountEventIn" messageType="ns1:ProcessAccountEventRequest"/>
+                </variables>
+
+                <sequence name="AccountSplitSequence">
+
+                    <!-- Extract message -->
+                    <assign name="extractAccountMessage">
+                        <sxt:trace>
+                            <sxt:log level="info" location="onComplete">
+                                <ns0:from>concat('*** Extracted accountMessage: ', sxxf:doMarshal($ProcessAccountEventIn.accountMessage))</ns0:from>
+                            </sxt:log>
+                        </sxt:trace>
+                        <copy>
+                            <from>$Messages/dt:accountMessages/dt:accountMessage[$AccountCounter]</from>
+                            <to>$ProcessAccountEventIn.accountMessage</to>
+                        </copy>
+                    </assign>
+
+                    <!-- Update accountyMessage -->
+                    <assign name="updateAccountMessage">
+                        <copy>
+                            <from>string($SOURCE_SYSTEM_ID)</from>
+                            <to>$ProcessAccountEventIn.accountMessage/dt:source</to>
+                        </copy>
+                        <copy>
+                            <from>string($TARGET_SYSTEM_ID)</from>
+                            <to>$ProcessAccountEventIn.accountMessage/dt:target</to>
+                        </copy>
+                    </assign>
+
+                    <invoke name="processAccountMessage" partnerLink="ObjectProcessor"  operation="processAccountEvent"
+                                                                                        portType="ns1:ObjectProcessorPortType"
+                                                                                        inputVariable="ProcessAccountEventIn"/>
+
+                </sequence>
+            </scope>
+        </forEach>
+
     </sequence>
 </process>


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.