diff --git a/index.js b/index.js index 798c2e2..496aeb6 100644 --- a/index.js +++ b/index.js @@ -135,7 +135,7 @@ function adapter(uri, opts){ Redis.prototype.broadcast = function(packet, opts, remote){ Adapter.prototype.broadcast.call(this, packet, opts); - if (!remote) { + if (!remote && (!opts || !opts.flags || !opts.flags.local)) { var chn = prefix + '#' + packet.nsp + '#'; var msg = msgpack.encode([uid, packet, opts]); if (opts.rooms) { diff --git a/package.json b/package.json index e01446c..5b959b3 100644 --- a/package.json +++ b/package.json @@ -13,7 +13,7 @@ "async": "0.9.0", "debug": "2.2.0", "msgpack-js": "0.3.0", - "redis": "2.4.2", + "redis": "2.6.2", "socket.io-adapter": "0.4.0", "uid2": "0.0.3" },