diff --git a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
index c0e41864e..e877ca750 100644
--- a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
+++ b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
@@ -265,11 +265,15 @@ class PoolRequests {
         errorMessage: String,
     ) {
         relayState.forEach { subId, state ->
-            desiredSubListeners.get(subId)?.onCannotConnect(
-                message = errorMessage,
-                relay = url,
-                forFilters = state.lastKnownFilterStates(url),
-            )
+            // These are all my subs.. need to figure out which relays have them
+            val subs = desiredSubs.get(subId)
+            if (subs != null && url in subs.keys) {
+                desiredSubListeners.get(subId)?.onCannotConnect(
+                    relay = url,
+                    message = errorMessage,
+                    forFilters = state.lastKnownFilterStates(url),
+                )
+            }
         }
     }