diff --git a/src/signaling/mcu_janus.go b/src/signaling/mcu_janus.go
index d712c52..eec0585 100644
--- a/src/signaling/mcu_janus.go
+++ b/src/signaling/mcu_janus.go
@@ -1061,7 +1061,7 @@ func (p *mcuJanusSubscriber) joinRoom(ctx context.Context, callback func(error,
 retry:
 	join_msg := map[string]interface{}{
 		"request": "join",
-		"ptype":   "listener",
+		"ptype":   "subscriber",
 		"room":    p.roomId,
 		"feed":    streamTypeUserIds[p.streamType],
 	}