Exemple de processus scalable - Historique des versions

Syfre le 20 janvier 2015 à 13:02

2015-01-20T13:02:30Z

← Version précédente		Version du 20 janvier 2015 à 13:02
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.		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:Architecture]]~~
	[[Category:File d'attente]]		[[Category:File d'attente]]
	[[Category:~~Latest~~]]		[[Category:Cluster]]
			[[Category:Version700]]

Syfre le 25 mars 2014 à 11:52

2014-03-25T11:52:13Z

← Version précédente		Version du 25 mars 2014 à 11:52
Ligne 324 :		Ligne 324 :

	[[Category:Architecture]]		[[Category:Architecture]]
			[[Category:File d'attente]]
	[[Category:Latest]]		[[Category:Latest]]

Syfre le 3 décembre 2013 à 08:41

2013-12-03T08:41:02Z

← Version précédente		Version du 3 décembre 2013 à 08:41
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.		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]]		[[Category:Latest]]

Syfre : /* Code du processus */

2013-12-01T08:21:41Z

Code du processus

← Version précédente		Version du 1 décembre 2013 à 08:21
Ligne 123 :		Ligne 123 :
	var aMsg:TdbmQueueMessage; aTopic:string; idx:Integer;		var aMsg:TdbmQueueMessage; aTopic:string; idx:Integer;
	begin		begin
			// Main code of the processus
	if Assigned(UserContext.TaskContext) then		if Assigned(UserContext.TaskContext) then
	begin		begin
			// The processus has been started by the scheduler
			//
	UserContext.TaskContext.AddMessage('MyProcessus.Execute');		UserContext.TaskContext.AddMessage('MyProcessus.Execute');
	if Assigned(UserContext.TaskContext.EventContext.receivedMsg) then		if Assigned(UserContext.TaskContext.EventContext.receivedMsg) then
	begin		begin
			// The scheduler task has consumed one object from the queue.
			//
	aMsg := UserContext.TaskContext.EventContext.receivedMsg;		aMsg := UserContext.TaskContext.EventContext.receivedMsg;
	UserContext.TaskContext.AddMessage(Format('Message :%s',[aMsg.queueTopic]]);		UserContext.TaskContext.AddMessage(Format('Message :%s',[aMsg.queueTopic]]);
Ligne 137 :		Ligne 142 :
	else		else
	begin		begin
			// The scheduler task is not queue based.
			//
	UserContext.TaskContext.AddMessage('No message, process as a regular task');		UserContext.TaskContext.AddMessage('No message, process as a regular task');
	doTask;		doTask;
	end;		end;
	end		end
	else doTask; // started by the UI		else doTask; // The processus has been started by the UI
	end;		end;
	</source>		</source>

Syfre : /* Traitement des objets avec regroupement */

2013-08-27T13:26:45Z

Traitement des objets avec regroupement

← Version précédente		Version du 27 août 2013 à 13:26
Ligne 275 :		Ligne 275 :
	// Get a list of queue objects with this topic		// Get a list of queue objects with this topic
	aList := MyQueue.deQueueList(aGroupByTopic);		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		if Assigned(aList) and (aList.Count>0) then
	try		try

Syfre : /* Traitement des objets avec regroupement */

2013-08-27T13:25:45Z

Traitement des objets avec regroupement

← Version précédente		Version du 27 août 2013 à 13:25
Ligne 244 :		Ligne 244 :

	Le principe est le suivant :		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 :		L'exemple précédent est modifié en remplaçant la procédure DeQueue :

Syfre : /* En traitement au fil de l'eau */

2013-08-27T13:24:49Z

En traitement au fil de l'eau

← Version précédente		Version du 27 août 2013 à 13:24
Ligne 229 :		Ligne 229 :
	{{#images:image3.png\|multitenant/example1}}		{{#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>		<pre>
Ligne 235 :		Ligne 235 :
	</pre>		</pre>

	* Si RequeueTopicXXXPattern ne sont pas définis l'objet de la file d'attente sera supprimé		* Si RequeueTopicXXXPattern ne sont pas définis l'objet de la file d'attente sera supprimé

	===Traitement des objets avec regroupement===		===Traitement des objets avec regroupement===

Syfre : /* Code du processus */

2013-08-27T13:22:55Z

Code du processus

← Version précédente		Version du 27 août 2013 à 13:22
Ligne 102 :		Ligne 102 :
	if Assigned(inst) then		if Assigned(inst) then
	begin		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		// here we change the state of the object
	inst.unEtat.value := WFCAState_Etat2;		inst.unEtat.value := WFCAState_Etat2;

Syfre le 7 juin 2013 à 13:54

2013-06-07T13:54:56Z

@@ Ligne 237 : / Ligne 237 : @@
 * Si RequeueTopicXXXPattern ne sont pas définis l'objet de la file d'attente sera supprimé
 [[Category:Multi-tenant]]
 [[Category:Latest]]

Syfre : /* Exécution au fil de l'eau */

2013-05-13T07:30:24Z

Exécution au fil de l'eau

← Version précédente		Version du 13 mai 2013 à 07:30
Ligne 155 :		Ligne 155 :
	===Exécution au fil de l'eau===		===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 :		L'automate est configuré ainsi :

Exemple de processus scalable - Historique des versions

Syfre le 20 janvier 2015 à 13:02

Syfre le 25 mars 2014 à 11:52

Syfre le 3 décembre 2013 à 08:41

Syfre : /* Code du processus */

Syfre : /* Traitement des objets avec regroupement */

Syfre : /* Traitement des objets avec regroupement */

Syfre : /* En traitement au fil de l'eau */

Syfre : /* Code du processus */

Syfre le 7 juin 2013 à 13:54

Syfre : /* Exécution au fil de l'eau */

Syfre : /* Code du processus */

Syfre : /* Traitement des objets avec regroupement */

Syfre : /* Traitement des objets avec regroupement */

Syfre : /* En traitement au fil de l'eau */

Syfre : /* Code du processus */

Syfre : /* Exécution au fil de l'eau */