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 | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
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 | ||||||
---|---|---|---|---|---|---|
|