SimpleExternalRabbitMQ

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

publishMessage

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

Параметры:

Название

Тип

Обязательно

Значение по умолчанию

routingKey

String

Д

Н

payLoad

String

Д

Н

options

Object

Д

Н

Поле	Тип	Значение
Exchange	string	не задано
Mandatory	boolean	false
Immediate	boolean	false
Headers	object	{}
ContentType	string	text/plain
ContentEncoding	string	не задано
DeliveryMode	byte	1
Priority	byte	0
CorrelationId	string	не задано
ReplyTo	string	не задано
Expiration	string	не задано
MessageId	string	не задано
Timestamp	string	0001-01-01 00:00:00
UserId	string	не задано
AppId	string	не задано
Type	string	не задано

Возвращает:

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

Пример:

publishMessage

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());

Page tree

SimpleExternalRabbitMQ

publishMessage