Базовый модуль модуля

модуль мк

модуль очереди сообщений

объект

Message

Создайте объект сообщения, см.Message

1
Message mq.Message;

HttpHandler

Создаватьhttpобъект обработчика протокола, см.HttpHandler

1
HttpHandler mq.HttpHandler;

Handler

Создайте объект процессора сообщений, передайте значение встроенному процессору и верните его напрямую.

1
Handler mq.Handler;

Результаты возврата:

  • Возвращает процессор, инкапсулирующий функцию обработки.

hdlr принимает встроенные процессоры сообщений, функции обработки, массивы цепочки обработки и объекты маршрутизации:

  • Функция Функция javascript, эта функция будет использоваться для обработки
  • HandlerВстроенный процессор, этот процессор будет использоваться для обработки
  • Обработка массивов в цепочке эквивалентна возврату новыхmq.Chain(hdlr), см.Chain
  • Объект маршрутизации, эквивалентный возврату новогоmq.Routing(hdlr), см.Routing

Синтаксис функции обработки сообщений следующий:

1
function func(v) {}

Параметр v — это обрабатываемое сообщение. Допускаются четыре типа возвращаемых результатов:

  • Функция javascript функция, эта функция будет использоваться на следующем этапе обработки
  • HandlerВстроенный процессор, этот процессор будет использоваться на следующем этапе обработки.
  • Цепная обработка массивов, эквивалентная новымmq.Chain(в), см.Chain
  • Объект маршрутизации, эквивалентный новомуmq.Routing(в), см.Routing

Отсутствие возврата или другого возвращаемого результата приведет к завершению обработки сообщения.


Chain

Создайте объект обработки цепочки обработчиков сообщений, см.Chain

1
Chain mq.Chain;

Routing

Создайте объект маршрутизации обработчика сообщений, см.Routing

1
Routing mq.Routing;

статическая функция

nullHandler

Создайте пустой объект процессора, и объект вторичной обработки будет возвращен напрямую без какой-либо обработки.

1
static Handler mq.nullHandler();

Результаты возврата:

  • Handler, возвращает пустую функцию-обработчик

invoke

Обработать сообщение или объект, используя данный обработчик

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

Параметры звонка:

  • hdlr:Handler, указывает процессор, который будет использоваться
  • v:object, укажите сообщение или объект для обработки

В отличие от метода вызова процессора, этот метод будет проходить через обработчик возврата каждого процессора, пока процессор не вернет ноль.