Вспомогательный прокси для взаимодействия с очередью сообщений
Как подключить
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) => {
});