diff --git a/index.mjs b/index.mjs
index bb4aac5..a4c56ba 100644
--- a/index.mjs
+++ b/index.mjs
@@ -35,21 +35,21 @@ connections
         // processed in order (sorted on sequence) and emitted in order
         // to clients to prevent async tx sequence problems.
       ] })
-
-      c.on("validation", validation => onValidation({
-        connectionUrl: c.getState()?.server?.uri,
-        networkId: c.getState()?.server?.networkId,
-        validation,
-      }))
-
-      c.on("ledger", ledger => onLedger({
-        connectionUrl: c.getState()?.server?.uri,
-        networkId: c.getState()?.server?.networkId,
-        ledger,
-        connection: c,
-      }))
     }
 
+    c.on("validation", validation => onValidation({
+      connectionUrl: c.getState()?.server?.uri,
+      networkId: c.getState()?.server?.networkId,
+      validation,
+    }))
+
+    c.on("ledger", ledger => onLedger({
+      connectionUrl: c.getState()?.server?.uri,
+      networkId: c.getState()?.server?.networkId,
+      ledger,
+      connection: c,
+    }))
+
     c.on('online', () => subscribe())
 
     c.on('error', e => console.error(e?.message || e))