From f10786a6adbdcff63a6a46b1b31936a795623766 Mon Sep 17 00:00:00 2001 From: Hans Date: Wed, 20 Sep 2023 23:02:40 +0800 Subject: [PATCH] feat: expose client error --- src/simple-mq.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/simple-mq.ts b/src/simple-mq.ts index 5e67d2d..c515efa 100644 --- a/src/simple-mq.ts +++ b/src/simple-mq.ts @@ -101,6 +101,9 @@ export class SimpleMQBroker extends EventEmitter { protected handleClient(client: Client) { let id: string | undefined; let session: MQClientSession | undefined; + client.on('error', (err) => { + this.emit('error', err); + }); client.on('close', () => { if (id && session) { delete this.clients[id!];