Módulo Módulo básico

Módulo mq

Módulo de cola de mensajes

Objeto

Message

Cree un objeto de mensaje, vea Message

1
Message mq.Message;

HttpHandler

Cree un objeto de procesador de protocolo http , consulte HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Cree un objeto procesador de mensajes, pase el valor directamente al procesador incorporado y devuelva

1
Handler mq.Handler;

Resultado de devolución:

  • Devuelve el procesador que encapsula la función de procesamiento.

hdlr acepta procesadores de mensajes integrados, funciones de procesamiento, matrices de procesamiento encadenadas y objetos de enrutamiento:

  • Función javascript, utilizará esta función para procesar
  • Handler procesador incorporado del controlador utilizará este procesador para procesar
  • El encadenamiento de matrices es equivalente a devolver un nuevo mq.Chain (hdlr), ver Chain
  • Objeto de enrutamiento, equivalente a devolver un nuevo mq.Routing (hdlr), consulte Routing

La sintaxis de la función de procesamiento de mensajes es la siguiente:

1
function func(v) {}

El parámetro v es el mensaje que se está procesando y el resultado de retorno permite cuatro tipos:

  • La función javascript de la función, usará esta función para la siguiente etapa de procesamiento
  • Handler procesador incorporado del controlador utilizará este procesador para la siguiente etapa de procesamiento
  • mq.Chain encadenado, equivalente al nuevo mq.Chain (v), ver Chain
  • Objeto de enrutamiento, equivalente al nuevo mq.Routing (v), consulte Routing

Ninguna devolución u otros resultados de devolución finalizarán el procesamiento del mensaje.


Chain

Cree un objeto de procesamiento de cadena de procesador de mensajes, consulte Chain

1
Chain mq.Chain;

Routing

Cree un objeto de enrutamiento del procesador de mensajes, consulte Routing

1
Routing mq.Routing;

Función estática

nullHandler

Cree un objeto de procesador vacío, el objeto de procesamiento secundario regresa directamente sin ningún procesamiento

1
static Handler mq.nullHandler();

Resultado de devolución:

  • Handler , devuelve la función de manejador vacío

invoke

Use un procesador dado para procesar un mensaje u objeto

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

Parámetros de llamada:

  • hdlr : Handler , especifique el procesador a usar
  • v : object , especifique el mensaje u objeto a procesar

A diferencia del método de invocación de un procesador, este método llamará al procesador de retorno de cada procesador en un bucle hasta que el procesador devuelva nulo.