Mòdul mòdul bàsic

mòdul mq

mòdul de cua de missatges

objecte

Message

Creeu un objecte de missatge, vegeuMessage

1
Message mq.Message;

HttpHandler

Crearhttpobjecte gestor de protocols, vegeuHttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Creeu un objecte processador de missatges, passeu el valor al processador integrat i retorneu-lo directament

1
Handler mq.Handler;

Resultats de retorn:

  • Retorna el processador que encapsula la funció de processament

hdlr accepta processadors de missatges integrats, funcions de processament, matrius de processament encadenats i objectes d'encaminament:

  • Funció funció javascript, aquesta funció s'utilitzarà per al processament
  • HandlerProcessador integrat, aquest processador s'utilitzarà per al processament
  • Processar matrius en una cadena és equivalent a retornar nousmq.Chain(hdlr), veureChain
  • Objecte d'encaminament, equivalent a retornar noumq.Routing(hdlr), veureRouting

La sintaxi de la funció de processament de missatges és la següent:

1
function func(v) {}

El paràmetre v és el missatge que s'està processant i es permeten quatre tipus de resultats de retorn:

  • Funció javascript, aquesta funció s'utilitzarà per a la següent etapa de processament
  • HandlerProcessador integrat, aquest processador s'utilitzarà per a la següent etapa de processament
  • Processament en cadena de matrius, equivalent a noumq.Chain(v), vegeuChain
  • Objecte d'encaminament, equivalent a noumq.Routing(v), vegeuRouting

Cap devolució o cap altre resultat de retorn acabarà amb el processament del missatge.


Chain

Creeu un objecte de processament de cadena de gestor de missatges, vegeuChain

1
Chain mq.Chain;

Routing

Creeu un objecte d'encaminament del gestor de missatges, vegeuRouting

1
Routing mq.Routing;

funció estàtica

nullHandler

Creeu un objecte de processador buit i l'objecte de processament secundari es retornarà directament sense cap processament.

1
static Handler mq.nullHandler();

Resultats de retorn:

  • Handler, retorna una funció de controlador buida

invoke

Processa un missatge o objecte utilitzant el controlador donat

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

Paràmetres de trucada:

  • hdlr:Handler, especifica el processador a utilitzar
  • v:object, especifiqueu el missatge o l'objecte a processar

A diferència del mètode d'invocació del processador, aquest mètode recorrerà el controlador de retorn de cada processador fins que el processador torni nul.