Модуль mq

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

Объект

Message

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

1
Message mq.Message;

---

HttpHandler

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

1
HttpHandler mq.HttpHandler;

---

Handler

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

1
Handler mq.Handler;

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

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

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

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

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

1
function func(v) {}

Параметр v - это обрабатываемое сообщение, а возвращаемый результат допускает четыре типа:

• Функция javascript function, эта функция будет использоваться на следующем этапе обработки
• Handler Встроенный процессор, этот процессор будет использоваться на следующем этапе обработки
• Массив цепной обработки, эквивалентный новому mq.Chain(v) см. Chain
• Объект маршрута, эквивалентный новому mq.Routing(v) см. 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, Укажите сообщение или объект для обработки

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