« Tâche consommation de file d'attente (automate) » : différence entre les versions
Aucun résumé des modifications |
m (Remplacement du texte — « Category:Latest » par « Category:Version700 ») |
||
| (3 versions intermédiaires par le même utilisateur non affichées) | |||
| Ligne 1 : | Ligne 1 : | ||
{{new|700}} | |||
La tâche consommation de file d'attente permet d'exécuter des actions sur réception d'un message de file d'attente. | La tâche consommation de file d'attente permet d'exécuter des actions sur réception d'un message de file d'attente. | ||
| Ligne 26 : | Ligne 27 : | ||
msg.QueueName := 'DBQUEUE1'; | msg.QueueName := 'DBQUEUE1'; | ||
msg.AddParameter('message.action','importdip'); | msg.AddParameter('message.action','importdip'); | ||
msg.AddParameter('message.accessToken','00000000F0EE180090761709D8004D006F6F1AC0A....F98117FDBD233311D83743B9DB'); | |||
msg.AddParameter('import.name','testimport-wfclassea.dip'); | msg.AddParameter('import.name','testimport-wfclassea.dip'); | ||
msg.BinaryContent.LoadFromFile('c:\temp\exports\wfclassea.txt'); | msg.BinaryContent.LoadFromFile('c:\temp\exports\wfclassea.txt'); | ||
| Ligne 39 : | Ligne 41 : | ||
[[Category:Tâches d'automate]] | [[Category:Tâches d'automate]] | ||
[[Category:File d'attente]] | [[Category:File d'attente]] | ||
[[Category: | [[Category:Version700]] | ||
Dernière version du 13 janvier 2015 à 08:56
| stock}} |
La tâche consommation de file d'attente permet d'exécuter des actions sur réception d'un message de file d'attente.
Cette tâche doit être utilisée avec un évènement file d'attente.
Les actions supportées part cette tâche sont:
- Import de données à partir d'un descriptif (.dip)
- Import de données à partir d'un format
- Exécution d'un processus.
La structure du message reçu doit correspondre à celle d'un message de traitement.
|
Tip : Cette tâche ne prend aucun paramètre car ceux-ci sont contenus dans le message |
Exemple :
Le code suivant poste un message dans une file d'attente qui permet d'importer un fichier :
<source lang="delphi"> //Procedure TestInQueueImport; var msg:TdbmQueueMessage; idx:Integer; begin
for idx:=1 to 1 do
begin
msg := TdbmQueueMessage.Create;
msg.QueueName := 'DBQUEUE1';
msg.AddParameter('message.action','importdip');
msg.AddParameter('message.accessToken','00000000F0EE180090761709D8004D006F6F1AC0A....F98117FDBD233311D83743B9DB');
msg.AddParameter('import.name','testimport-wfclassea.dip');
msg.BinaryContent.LoadFromFile('c:\temp\exports\wfclassea.txt');
msg.Post;
end;
end; </source>
{{#if:Automates|
{{#if:Automates|— Automates |}} — Développement DSM —
|
{{#if:|— [[{{{1}}}]] |}} — Développement DSM —
}}