Модуль mq
Модуль очереди сообщений
Объект
Message
Создайте объект сообщения, см. Message
1Message mq.Message;
HttpHandler
Создавать http Объект обработчика протокола, см. HttpHandler
1HttpHandler mq.HttpHandler;
Handler
Создайте объект обработчика сообщений, передайте значение, которое встроенный обработчик напрямую возвращает
1Handler mq.Handler;
Результат возврата:
- Возвращает процессор, который инкапсулирует функцию обработки.
hdlr принимает встроенные обработчики сообщений, функции обработки, массивы обработки цепочки и объекты маршрутизации:
- Функция javascript function, будет использовать эту функцию для обработки
- Handler Встроенный процессор, будет использовать этот процессор для обработки
- Массив обработки цепочки, эквивалентный возврату нового mq.Chain(hdlr) см. Chain
- Объект маршрута, эквивалентный возврату нового mq.Routing(hdlr) см. Routing
Синтаксис функции обработки сообщений следующий:
1function func(v) {}
Параметр v - это обрабатываемое сообщение, а возвращаемый результат допускает четыре типа:
- Функция javascript function, эта функция будет использоваться на следующем этапе обработки
- Handler Встроенный процессор, этот процессор будет использоваться на следующем этапе обработки
- Массив цепной обработки, эквивалентный новому mq.Chain(v) см. Chain
- Объект маршрута, эквивалентный новому mq.Routing(v) см. Routing
Отсутствие возврата или других результатов возврата не приведет к прекращению обработки сообщения.
Chain
Создайте объект обработки цепочки обработчика сообщений, см. Chain
1Chain mq.Chain;
Routing
Создайте объект маршрутизации обработчика сообщений, см. Routing
1Routing mq.Routing;
Статическая функция
nullHandler
Создайте пустой объект обработчика, и вторичный обработчик вернется напрямую без какой-либо обработки.
1static Handler mq.nullHandler();
Результат возврата:
- Handler, Вернуть пустой обработчик
invoke
Использовать данный процессор для обработки сообщения или объекта
1
2static mq.invoke(Handler hdlr,
object v) async;
Параметры звонка:
В отличие от метода invoke процессора, этот метод будет вызывать обработчик возврата каждого процессора в цикле до тех пор, пока процессор не вернет значение null.