Exemple de processus scalable - Historique des versions

Syfre le 20 janvier 2015 à 13:02

2015-01-20T13:02:30Z

2014-03-25T11:52:13Z

2013-12-03T08:41:02Z

2013-12-01T08:21:41Z

Code du processus

2013-08-27T13:26:45Z

Traitement des objets avec regroupement

2013-08-27T13:25:45Z

Traitement des objets avec regroupement

2013-08-27T13:24:49Z

En traitement au fil de l'eau

2013-08-27T13:22:55Z

Code du processus

2013-06-07T13:54:56Z

2013-05-13T07:30:24Z

Exécution au fil de l'eau

@@ Ligne 323 : / Ligne 323 : @@
 En cas d'erreur on replace dans la file les objets de la liste (ReQueueList) en une opération en prenant soin de changer le sujet pour éviter de créer des objets poisons.
 [[Category:File d'attente]]
-[[Category:Latest]]
+[[Category:Cluster]]

@@ Ligne 323 : / Ligne 323 : @@
 En cas d'erreur on replace dans la file les objets de la liste (ReQueueList) en une opération en prenant soin de changer le sujet pour éviter de créer des objets poisons.
-[[Category:Multi-tenant]]
+[[Category:Architecture]]
 [[Category:Latest]]

@@ Ligne 123 : / Ligne 123 : @@
 var aMsg:TdbmQueueMessage; aTopic:string; idx:Integer;
 begin
    if Assigned(UserContext.TaskContext) then
     begin
       UserContext.TaskContext.AddMessage('MyProcessus.Execute');
       if Assigned(UserContext.TaskContext.EventContext.receivedMsg) then
         begin
           aMsg := UserContext.TaskContext.EventContext.receivedMsg;
           UserContext.TaskContext.AddMessage(Format('Message :%s',[aMsg.queueTopic]]);
@@ Ligne 137 : / Ligne 142 : @@
         else
         begin
           UserContext.TaskContext.AddMessage('No message, process as a regular task');
           doTask;
         end;
     end
-    else doTask; // started by the UI
+    else doTask; // The processus has been started by the UI
 end;
 </source>

@@ Ligne 275 : / Ligne 275 : @@
         // Get a list of queue objects with this topic
         aList := MyQueue.deQueueList(aGroupByTopic);
-        // the objects may has been consumed by an other process, so we have to check it again.
+        // the objects may have been consumed by an other process, so we have to check it again.
         if Assigned(aList) and (aList.Count>0) then
           try

@@ Ligne 244 : / Ligne 244 : @@
 Le principe est le suivant :
-* On interroge la queue pour obtenir le premier objet traitable (GetFirst).
+* On interroge la file d'attente pour obtenir le premier objet traitable (GetFirst).
-* On extrait du topic obtenu le critère de regroupement souhaité (ici en utilisant StringPart).
+* On extrait du sujet obtenu le critère de regroupement souhaité (ici en utilisant StringPart).
-* On obtient de la file tous les objets vérifiant ce sujet (DeQueueList).
+* On obtient de la file d'attente tous les objets vérifiant ce sujet (DeQueueList).
 L'exemple précédent est modifié en remplaçant la procédure DeQueue :

@@ Ligne 229 : / Ligne 229 : @@
 {{#images:image3.png|multitenant/example1}}
-* Si RequeueTopicXXXPattern sont définis l'objet se réactivé dans la file d'attente (ici MyQueue) avec le nouveau sujet défini par
+* Si RequeueTopicXXXPattern sont définis l'objet sera réactivé dans la file d'attente (ici MyQueue) avec le nouveau sujet défini par
 <pre>
@@ Ligne 235 : / Ligne 235 : @@
 </pre>
 * Si RequeueTopicXXXPattern ne sont pas définis l'objet de la file d'attente sera supprimé
 ===Traitement des objets avec regroupement===

@@ Ligne 102 : / Ligne 102 : @@
       if Assigned(inst) then
        begin
-         // this is the process core where business transformations are apply.
+         // this is the process main code where business transformations are applied.
          // here we change the state of the object
          inst.unEtat.value := WFCAState_Etat2;

@@ Ligne 155 : / Ligne 155 : @@
 ===Exécution au fil de l'eau===
-Lorsque le processus est exécuté par une tâche d'automate déclenché par un [[Evènement_file_d'attente_(automate)|évènement file d'attente]] il extrait du [[Contexte_de_tâche_(automate)|contexte de l'automate]] le message reçu de la file d'attente (Execute) et exécute directement le code de traitement (doProcess).
+Lorsque le processus est exécuté par une tâche d'automate déclenchée par un [[Evènement_file_d'attente_(automate)|évènement file d'attente]] il extrait du [[Contexte_de_tâche_(automate)|contexte de l'automate]] le message reçu de la file d'attente (Execute) et exécute directement le code de traitement (doProcess).
 L'automate est configuré ainsi :