diff --git a/pkg/routing/redisrouter.go b/pkg/routing/redisrouter.go
index d31a13638..f10f77859 100644
--- a/pkg/routing/redisrouter.go
+++ b/pkg/routing/redisrouter.go
@@ -160,8 +160,9 @@ func (r *RedisRouter) StartParticipantSignal(ctx context.Context, roomName livek
 		return
 	}
 
-	// create a new connection id
-	connectionID = livekit.ConnectionID(utils.NewGuid("CO_"))
+	if connectionID == "" {
+		connectionID = livekit.ConnectionID(utils.NewGuid("CO_"))
+	}
 	pKey := ParticipantKeyLegacy(roomName, pi.Identity)
 	pKeyB62 := ParticipantKey(roomName, pi.Identity)
 
diff --git a/pkg/routing/signal.go b/pkg/routing/signal.go
index fad31191b..aa94b12dc 100644
--- a/pkg/routing/signal.go
+++ b/pkg/routing/signal.go
@@ -80,7 +80,7 @@ func (r *signalClient) StartParticipantSignal(
 		"room", roomName,
 		"reqNodeID", nodeID,
 		"participant", pi.Identity,
-		"connectionID", connectionID,
+		"connID", connectionID,
 	)
 
 	l.Debugw("starting signal connection")