aa
Some checks failed
test / Run tests (push) Failing after 11s
build / Build (push) Failing after 16s

This commit is contained in:
2025-02-12 23:12:03 +08:00
parent 3a41bf0f21
commit fcf9f6fd63
3 changed files with 4 additions and 8 deletions

View File

@ -14,7 +14,6 @@ export class Broker {
LoggerCore.getInstance().logger({ service: "messageQueue" }).debug("subscribe", { topic });
const con = await this.msg.connect({ action: "messageQueue", data: { action: "subscribe", topic } });
con.onMessage((msg: { action: string; topic: string; message: any }) => {
console.log(msg);
if (msg.action === "message") {
handler(msg.message);
}