diff --git a/plugins/signals-node/src/SignalsService.ts b/plugins/signals-node/src/SignalsService.ts
index 6a1547a6bb..c743c958dd 100644
--- a/plugins/signals-node/src/SignalsService.ts
+++ b/plugins/signals-node/src/SignalsService.ts
@@ -206,6 +206,11 @@ export class SignalsService implements EventSubscriber {
       ) {
         return;
       }
+
+      if (conn.ws.readyState !== WebSocket.OPEN) {
+        return;
+      }
+
       conn.ws.send(jsonMessage);
     });
 
diff --git a/plugins/signals/src/api/SignalsClient.ts b/plugins/signals/src/api/SignalsClient.ts
index d8d3328411..1fbe374ad9 100644
--- a/plugins/signals/src/api/SignalsClient.ts
+++ b/plugins/signals/src/api/SignalsClient.ts
@@ -126,7 +126,7 @@ export class SignalsClient implements SignalsApi {
     const { token } = await this.identity.getCredentials();
 
     const url = new URL(apiUrl);
-    url.protocol = url.protocol === 'http:' ? 'ws' : 'wss';
+    url.protocol = url.protocol === 'http:' ? 'ws:' : 'wss:';
     this.ws = new WebSocket(url.toString(), token);
 
     this.ws.onmessage = (data: MessageEvent) => {