diff --git a/api/src/actors/socket_session.rs b/api/src/actors/socket_session.rs
index d4542a5..f705d87 100644
--- a/api/src/actors/socket_session.rs
+++ b/api/src/actors/socket_session.rs
@@ -56,4 +56,4 @@ impl StreamHandler<Result<ws::Message, ws::ProtocolError>> for SocketSession {
                 let m = text.trim();
                 if m.starts_with('/') {
                     let v: Vec<&str> = m.splitn(2, ' ').collect();
-                    if v
\ No newline at end of file
+                    if v[0] == "/subscribe" {