aux-broker-mq

Вспомогательный прокси для взаимодействия с очередью сообщений

Как подключить

import { BrokerProxy } from "./dist/BrokerProxy";
const broker = new BrokerProxy({ host: "guest:guest@localhost" });
// ... async context {
    await broker.connect();
    await broker.createChannel("test");
// }

Как работать

Отправка сообщений

 broker.emit("testService.Update", { value: Object });

Получение сообщений

interface Event {
    value: Object
}
broker.on<Event>("testService.Update").subscribe((msg: Event) => {
     
});