Versions Compared

Old Version 1

changes.mady.by.user Dina Baksheeva

Saved on

compared with

New Version 2

changes.mady.by.user Dina Baksheeva

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Этот класс серверного API создан для формирования и отправки сообщений в стороннюю очередь AMPQ.

publishMessage

Метод отправляет сообщение в выбранную очередь.

Параметры:

НазваниеТипОбязательноЗначение по умолчанию
routingKeyStringДН
payLoadStringДН
optionsObjectД

Н

Expand
titleДоступные поля


ПолеТип Значение
Exchangestringне задано
Mandatorybooleanfalse
Immediatebooleanfalse
Headersobject{}
ContentTypestringtext/plain
ContentEncodingstringне задано
DeliveryModebyte1
Prioritybyte0
CorrelationIdstringне задано
ReplyTostringне задано
Expirationstringне задано
MessageIdstringне задано
Timestampstring0001-01-01 00:00:00
UserIdstringне задано
AppIdstringне задано
Typestringне задано




Возвращает:

ТипОписание
SimpleExternalRabbitMQМетод возвращает этот же класс.


Пример:

Code Block
languagejs
themeConfluence
titlepublishMessage
linenumberstrue
const rabbitMq = new SimpleExternalRabbitMQ('nofication-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());