Merge 8245c9e into ad323e2

moscajs · Jun 13, 2015 · ba9f655 · ba9f655
2 parents ad323e2 + 8245c9e
commit ba9f655
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/persistence/redis.js b/lib/persistence/redis.js
@@ -104,7 +104,9 @@ function RedisPersistence(options, callback) {
       }
 
       Object.keys(subs).forEach(function(sub) {
-        that._subMatcher.add(sub, id);
+        if (that._subMatcher.match(sub).indexOf(id) < 0) {
+          that._subMatcher.add(sub, id);
+        }
       });
 
       var redisError = null;