You are viewing an old version of this page. View the current version.
Compare with Current View Page History
« Previous Version 21 Current »
Этот класс серверного API содержит методы для формирования и отправки сообщений в стороннюю очередь на базе RabbitMQ.
Используйте метод для возврата сообщений об ошибке, если при отправке сообщения произошел сбой.
Возвращает:
Пример:
const rabbitMq = new SimpleExternalRabbitMQ('nofication-service'); const payload = { userIDs: [2344, 7444], message: "Hello!" } ss.info(rabbitMq.publishMessage('push-notifications', JSON.stringify(payload), {ContentType: "application/json", Headers: {"X-Source": "simple"}}).getErrors());
Используйте метод для отправки сообщения в выбранную очередь.
Максимальная длина сообщения – 26000 символов.
Параметры:
Н
const rabbitMq = new SimpleExternalRabbitMQ('nofication-service'); const payload = { userIDs: [2344, 7444], message: "Здравствуйте!" } ss.info(rabbitMq.publishMessage('push-notifications', JSON.stringify(payload), {ContentType: "application/json", Headers: {"X-Source": "simple"}}).getErrors());
Используйте метод для отправки массива сообщений в выбранную очередь.
const rabbitMq = new SimpleExternalRabbitMQ('notification-service'); const messages = [ { userID: 2344, message: "Здравствуйте, Иван" }, { userID: 7444, message: "Здравствуйте, Петр" } ]; rabbitMq.publishMultipleMessages( 'push-notifications', messages.map(m => JSON.stringify(m)), { ContentType: "application/json", Headers: { "X-Source": "simple" } } ) ss.info(rabbitMq.getErrors());
