wired up disconnect and websocket close handlers.

pb33f · Jan 5, 2025 · 9328f83 · 9328f83
1 parent de85e0d
commit 9328f83
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/bus_engine.ts b/src/bus_engine.ts
@@ -43,6 +43,19 @@ export class ranch implements Bus {
                 config.onConnect(frame);
             }
         }
+        this._stompClient.onDisconnect = (frame) => {
+            console.warn('Disconnected from the ranch')
+            if (config.onDisconnect) {
+                config.onDisconnect(frame);
+            }
+        }
+        this._stompClient.onWebSocketClose = ((frame: any) => {
+            console.warn('Socket connection to the ranch was closed, reconnecting...')
+            if (config.onDisconnect) {
+                config.onDisconnect(frame);
+            }
+        })
+        this._stompClient.activate()
     }
 
     private _mapDestination(destination: string, channel: string) {