Module module de base

Module mq

Module de file d'attente de messages

Objet

Message

Créer un objet de message, voir Message

1
Message mq.Message;

HttpHandler

Créez un objet de gestionnaire de protocole http , voir HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Créez un objet de gestionnaire de messages, passez la valeur que le gestionnaire intégré renvoie directement

1
Handler mq.Handler;

Résultat de retour:

  • Renvoie le processeur qui encapsule la fonction de traitement

hdlr accepte les gestionnaires de messages intégrés, les fonctions de traitement, les tableaux de traitement en chaîne et les objets de routage:

  • Fonction javascript, utilisera cette fonction pour le traitement
  • Handler processeur intégré du Handler utilisera ce processeur pour le traitement
  • Le traitement du tableau dans une chaîne équivaut à renvoyer un nouveau mq.Chain (hdlr), voir Chain
  • Objet de routage, équivalent à renvoyer un nouveau mq.Routing (hdlr), voir Routing

La syntaxe de la fonction de traitement des messages est la suivante:

1
function func(v) {}

Le paramètre v est le message en cours de traitement et le résultat renvoyé autorise quatre types:

  • Fonction javascript, cette fonction sera utilisée pour la prochaine étape du traitement
  • Processeur intégré au Handler , ce processeur sera utilisé pour la prochaine étape du traitement
  • Tableau de traitement de chaîne, équivalent à new mq.Chain (v), voir Chain
  • Objet de routage, équivalent au nouveau mq.Routing (v), voir Routing

Aucun retour ou autre résultat de retour ne mettra fin au traitement du message.


Chain

Créez un objet de traitement de chaîne de processeur de messages, voir Chain

1
Chain mq.Chain;

Routing

Créer un objet de routage du processeur de messages, voir Routing

1
Routing mq.Routing;

Fonction statique

nullHandler

Créez un objet gestionnaire vide, le gestionnaire secondaire retournera directement sans aucun traitement

1
static Handler mq.nullHandler();

Résultat de retour:

  • Handler , retourne une fonction de gestionnaire vide

invoke

Utiliser le processeur donné pour traiter un message ou un objet

1 2
static mq.invoke(Handler hdlr, object v) async;

Paramètres d'appel:

  • hdlr : Handler , spécifiez le processeur utilisé
  • v : object , spécifiez le message ou l'objet à traiter

Différente de la méthode invoke du processeur, cette méthode appellera le processeur de retour de chaque processeur dans une boucle jusqu'à ce que le processeur renvoie null.