Módulo mq

Módulo de cola de mensajes

Objeto

Message

Cree un objeto de mensaje, consulte Message

1
Message mq.Message;

HttpHandler

Cree un objeto de controlador de protocolo http , consulte HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Cree un objeto de controlador de mensajes, pase el valor que el controlador incorporado devuelve directamente

1
Handler mq.Handler;

Devolver resultado:

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

hdlr acepta controladores de mensajes integrados, funciones de procesamiento, matrices de procesamiento en cadena y objetos de enrutamiento:

• Función función javascript, utilizará esta función para procesar
• Handler procesador integrado, utilizará este procesador para el procesamiento
• Matriz de procesamiento en cadena, equivalente a devolver un nuevo mq.Chain (hdlr), consulte 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 la devolución permite cuatro tipos:

• Función función javascript, esta función se utilizará para la siguiente etapa de procesamiento
• Handler procesador incorporado, este procesador se usa para la siguiente etapa de procesamiento
• Matriz de procesamiento de cadena, equivalente a la nueva mq.Chain (v), consulte 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 controlador vacío, el controlador secundario regresará directamente sin ningún procesamiento

1
static Handler mq.nullHandler();

Devolver resultado:

• Handler , devuelve una función de controlador vacía

invoke

Utilizar un procesador determinado 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 utilizado
• v : object , especifique el mensaje u objeto a procesar

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