Module module de base

Module mq

Module de file d'attente de messages

Objet

Message

Créer un objet message, voir Message

1
Message mq.Message;

HttpHandler

Créer http Objet gestionnaire de protocole, voir HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Créez un objet de gestionnaire de messages, transmettez 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 fonction javascript, utilisera cette fonction pour le traitement
  • Handler Processeur intégré, utilisera ce processeur pour le traitement
  • Tableau de traitement en chaîne, équivalent au retour d'un nouveau mq.Chain(hdlr), voir Chain
  • Objet route, équivalent au retour d'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 de retour permet quatre types :

  • Fonction fonction javascript, cette fonction sera utilisée pour la prochaine étape de traitement
  • Handler Processeur intégré, ce processeur sera utilisé pour la prochaine étape de traitement
  • Tableau de traitement en chaîne, équivalent au nouveau mq.Chain(v), voir Chain
  • Objet route, équivalent à 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 de gestionnaire de messages, voir Routing

1
Routing mq.Routing;

Fonction statique

nullHandler

Créez un objet de gestionnaire vide et le gestionnaire secondaire reviendra directement sans aucun traitement

1
static Handler mq.nullHandler();

Résultat de retour :

  • Handler, Retourner le gestionnaire vide

invoke

Utiliser un 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, Le processeur spécifié
  • v: object, Spécifiez le message ou l'objet à traiter

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