Versions Compared
compared with
Key
- This line was added.
- This line was removed.
- Formatting was changed.
Этот класс серверного API создан содержит методы для формирования и отправки сообщений в стороннюю очередь на базе RabbitMQ.
getErrors()
Если Используйте метод для возврата сообщений об ошибке, если при отправке сообщения произошел сбой, этот метод отобразит сообщение об ошибке.
Используйте его для проверки вашего скрипта на наличие ошибок.
Возвращает:
Тип | Описание |
---|---|
Array of Strings | Значения ошибок. |
Пример:
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
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()); |
publishMessage()
Метод отправляет сообщение Используйте метод для отправки сообщения в выбранную очередь.
Note |
---|
Максимальная длина сообщения – 26000 символов. |
Параметры:
Название | Тип | Обязательно | Значение по умолчанию | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
routingKey | String | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
payload | String | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
options | Object | Н | Н
|
Возвращает:
Тип | Описание |
---|---|
SimpleExternalRabbitMQ | Метод возвращает экземпляр этого же класса, на котором был вызван. |
Пример:
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
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()); |
publishMultipleMessages()
Метод отправляет массив Используйте метод для отправки массива сообщений в выбранную очередь.
Note |
---|
Максимальная длина сообщения – 26000 символов. |
Параметры:
Название | Тип | Обязательно | Значение по умолчанию | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
routingKey | String | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
payloads | Array of Strings | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
options | Object | Н | Н
|
Возвращает:
Тип | Описание |
---|---|
SimpleExternalRabbitMQ | Метод возвращает экземпляр этого же класса, на котором был вызван. |
Пример:
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
const rabbitMq = new SimpleExternalRabbitMQ('notification-service'); const messages = [ { userID: 2344, message: "HelloЗдравствуйте, IvanИван" }, { userID: 7444, message: "HelloЗдравствуйте, PetrПетр" } ]; rabbitMq.publishMultipleMessages( 'push-notifications', messages.map(m => JSON.stringify(m)), { ContentType: "application/json", Headers: { "X-Source": "simple" } } ) ss.info(rabbitMq.getErrors()); |
Table of Contents | ||||||
---|---|---|---|---|---|---|
|