diff --git a/lib/ws.js b/lib/ws.js
index 352c59d..14aaeef 100644
--- a/lib/ws.js
+++ b/lib/ws.js
@@ -43,7 +43,7 @@ export function init(cfg, db) {
           case "subscribe":
             db.subscribe(
               message.subject,
-              message.filter
+              replaceIdInFilter(message.filter)
             ).then(r => ws.send(
               JSON.stringify({
                 subject: message.subject,