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