Versions Compared
compared with
Key
- This line was added.
- This line was removed.
- Formatting was changed.
Этот класс серверного API создан для формирования и отправки сообщений в стороннюю очередь AMPQ.
publishMessage
Метод отправляет сообщение в выбранную очередь.
Параметры:
Название | Тип | Обязательно | Значение по умолчанию | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
routingKey | String | Д | Н | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
payLoadpayload | 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()
Метод отправляет массив сообщений в выбранную очередь.
Параметры:
Название | Тип | Обязательно | Значение по умолчанию | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
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 | ||||||
---|---|---|---|---|---|---|
|