Módulo módulo básico

Módulo mq

Módulo de cola de mensaxes

Obxecto

Message

Crea un obxecto de mensaxe, ver Message

1
Message mq.Message;

HttpHandler

Crear http Obxecto manipulador de protocolo, ver HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Crea un obxecto de controlador de mensaxes, pasa o valor que devolve directamente o controlador incorporado

1
Handler mq.Handler;

Resultado de volta:

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

hdlr acepta controladores de mensaxes integrados, funcións de procesamento, matrices de procesamento de cadeas e obxectos de enrutamento:

  • Función javascript, empregará esta función para o procesamento
  • Handler O procesador incorporado utilizará este procesador para o seu procesamento
  • Matriz de procesamento de cadea, equivalente a volver novo mq.Chain(hdlr), ver Chain
  • Obxecto de ruta, equivalente a devolver o novo mq.Routing(hdlr), ver Routing

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

1
function func(v) {}

O parámetro v é a mensaxe que se está procesando e o resultado de devolución permite catro tipos:

  • Función Función javascript, esta función utilizarase para a seguinte etapa do procesamento
  • Handler Procesador incorporado, este procesador utilizarase para a seguinte etapa do procesamento
  • Matriz de procesamento de cadea, equivalente a nova mq.Chain(v), ver Chain
  • Obxecto de ruta, equivalente a novo mq.Routing(v), ver Routing

Sen devolución ou outros resultados de devolución finalizará o procesamento da mensaxe.


Chain

Crea un obxecto de procesamento de cadea de procesador de mensaxes, ver Chain

1
Chain mq.Chain;

Routing

Crea un obxecto de encamiñamento do controlador de mensaxes, ver Routing

1
Routing mq.Routing;

Función estática

nullHandler

Crea un obxecto de controlador baleiro e o controlador secundario volverá directamente sen ningún procesamento

1
static Handler mq.nullHandler();

Resultado de volta:

  • Handler, Devolver o controlador baleiro

invoke

Use un procesador determinado para procesar unha mensaxe ou obxecto

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

Parámetros de chamada:

  • hdlr: Handler, O procesador especificado
  • v: object, Especifique a mensaxe ou o obxecto a procesar

A diferenza do método de invocación do procesador, este método chamará ao procesador de volta de cada procesador nun bucle ata que o procesador devolva nulo.