feat: expose client error

mybigday · Sep 20, 2023 · f10786a · f10786a
1 parent 65454fb
commit f10786a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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!];