Módulo módulo básico

módulo mq

módulo de cola de mensaxes

obxecto

Message

Crea un obxecto de mensaxe, consulteMessage

1
Message mq.Message;

HttpHandler

Crearhttpobxecto do manejador de protocolos, véxaseHttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Crea un obxecto procesador de mensaxes, pasa o valor ao procesador integrado e devólveo directamente

1
Handler mq.Handler;

Resultados de devolución:

  • Devolve o procesador que encapsula a función de procesamento

hdlr acepta procesadores de mensaxes integrados, funcións de procesamento, matrices de procesamento encadeada e obxectos de enrutamento:

  • Función función javascript, esta función será usada para o procesamento
  • HandlerProcesador incorporado, este procesador utilizarase para o procesamento
  • Procesar matrices nunha cadea é equivalente a devolver novasmq.Chain(hdlr), verChain
  • Obxecto de enrutamento, equivalente a devolver novomq.Routing(hdlr), verRouting

A sintaxe da función de procesamento de mensaxes é a seguinte:

1
function func(v) {}

O parámetro v é a mensaxe que se está a procesar e permítense catro tipos de resultados de retorno:

  • Función función javascript, esta función será usada para a seguinte fase de procesamento
  • HandlerProcesador incorporado, este procesador empregarase para a seguinte fase de procesamento
  • Procesamento en cadea de matrices, equivalente a newmq.Chain(v), verChain
  • Obxecto de enrutamento, equivalente a newmq.Routing(v), verRouting

Ningún resultado de devolución ou outro resultado de devolución finalizará o procesamento da mensaxe.


Chain

Cree un obxecto de procesamento de cadea de controlador de mensaxes, consulteChain

1
Chain mq.Chain;

Routing

Cree un obxecto de enrutamento do manejador de mensaxes, consulteRouting

1
Routing mq.Routing;

función estática

nullHandler

Cree un obxecto de procesador baleiro e o obxecto de procesamento secundario devolverase directamente sen ningún procesamento.

1
static Handler mq.nullHandler();

Resultados de devolución:

  • Handler, devolve unha función controladora baleira

invoke

Procesa unha mensaxe ou obxecto usando o manejador indicado

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

Parámetros de chamada:

  • hdlr:Handler, especifica o procesador a utilizar
  • v:object, especifique a mensaxe ou o obxecto que se vai procesar

A diferenza do método de invocación do procesador, este método pasará polo controlador de retorno de cada procesador ata que o procesador devolva nulo.