diff --git a/README.md b/README.md
index dd94ea6..e3cc020 100644
--- a/README.md
+++ b/README.md
@@ -33,7 +33,7 @@ Develop your first microservices in under two minutes:
 in `time-service.js`...
 ```js
 const cote = require('cote');
-const timeService = new cote.Responder({name: 'Time Service'});
+const timeService = new cote.Responder({ name: 'Time Service' });
 
 timeService.on('time', (req, cb) => {
     cb(new Date());
@@ -43,9 +43,9 @@ timeService.on('time', (req, cb) => {
 in `client.js`...
 ```js
 const cote = require('cote');
-const client = new cote.Requester({name: 'Client'});
+const client = new cote.Requester({ name: 'Client' });
 
-client.send({type: 'time'}, (time) => {
+client.send({ type: 'time' }, (time) => {
     console.log(time);
 });
 ```
@@ -528,13 +528,13 @@ const randomRequester = new cote.Requester({
     name: 'Random Requester',
     // namespace: 'rnd',
     // key: 'a certain key',
-    requests: ['randomRequest']
+    requests: ['randomRequest'],
 });
 
 setInterval(() => {
     const req = {
         type: 'randomRequest',
-        val: Math.floor(Math.random() * 10)
+        val: Math.floor(Math.random() * 10),
     };
 
     randomRequester.send(req, (res) => {
@@ -551,13 +551,13 @@ Example:
 
 ```js
 const cote = require('cote');
-const randomRequester = new cote.Requester({name: 'Random Requester'});
+const randomRequester = new cote.Requester({ name: 'Random Requester' });
 
 const makeRequest = (req) => randomRequester.send(req);
 
 const req = {
     type: 'randomRequest',
-    val: Math.floor(Math.random() * 10)
+    val: Math.floor(Math.random() * 10),
 };
 
 makeRequest(req)
@@ -590,7 +590,7 @@ const randomResponder = new cote.Responder({
     name: 'Random Responder',
     // namespace: 'rnd',
     // key: 'a certain key',
-    respondsTo: ['randomRequest'] // types of requests this responder
+    respondsTo: ['randomRequest'], // types of requests this responder
                                   // can respond to.
 });
 
@@ -614,7 +614,7 @@ const cote = require('cote');
 const UserModel = require('UserModel'); // a promise-based model API such as
                                         // mongoose.
 
-const userResponder = new cote.Responder({name: 'User Responder'});
+const userResponder = new cote.Responder({ name: 'User Responder' });
 
 userResponder.on('find', (req) => UserModel.findOne(req.query));
 ```
@@ -622,11 +622,11 @@ userResponder.on('find', (req) => UserModel.findOne(req.query));
 `requester.js`
 ```js
 const cote = require('cote');
-const userRequester = new cote.Requester({name: 'User Requester'});
+const userRequester = new cote.Requester({ name: 'User Requester' });
 
 userRequester
-    .send({type: 'find', query: {username: 'foo'}})
-    .then(user => console.log(user))
+    .send({ type: 'find', query: { username: 'foo' } })
+    .then((user) => console.log(user))
     .then(process.exit);
 ```
 
@@ -656,13 +656,13 @@ const randomPublisher = new cote.Publisher({
     name: 'Random Publisher',
     // namespace: 'rnd',
     // key: 'a certain key',
-    broadcasts: ['randomUpdate']
+    broadcasts: ['randomUpdate'],
 });
 
 // Wait for the publisher to find an open port and listen on it.
 setInterval(function() {
     const val = {
-        val: Math.floor(Math.random() * 1000)
+        val: Math.floor(Math.random() * 1000),
     };
 
     console.log('emitting', val);
@@ -685,7 +685,7 @@ const randomSubscriber = new cote.Subscriber({
     name: 'Random Subscriber',
     // namespace: 'rnd',
     // key: 'a certain key',
-    subscribesTo: ['randomUpdate']
+    subscribesTo: ['randomUpdate'],
 });
 
 randomSubscriber.on('randomUpdate', (req) => {
@@ -707,25 +707,29 @@ Example:
 ```html
 <script src="/socket.io/socket.io.js"></script>
 <script>
-var socket = io.connect();
-var socketNamespaced = io.connect('/rnd');
+let socket = io.connect();
+let socketNamespaced = io.connect('/rnd');
+
+socket.on('randomUpdate', function(data) {
+    console.log(data);
+});
 
 setInterval(function() {
-    var req = {
-        val: Math.floor(Math.random() * 10)
+    let req = {
+        val: Math.floor(Math.random() * 10),
     };
 
-    var req2 = {
-        val: Math.floor(Math.random() * 10)
+    let req2 = {
+        val: Math.floor(Math.random() * 10),
     };
 
-    var req3 = {
-        val: Math.floor(Math.random() * 10)
+    let req3 = {
+        val: Math.floor(Math.random() * 10),
     };
 
-    var req4 = {
-        val: Math.floor(Math.random() * 10)
-    }
+    let req4 = {
+        val: Math.floor(Math.random() * 10),
+    };
 
     socket.emit('randomRequest', req, function(data) {
         console.log('normal', req.val, data);
@@ -753,6 +757,10 @@ const cote = require('cote'),
     io = require('socket.io').listen(app),
     fs = require('fs');
 
+io.on('connection', (socket) => {
+    socket.join('room1');
+});
+
 app.listen(process.argv[2] || 5555);
 
 function handler(req, res) {
@@ -772,11 +780,26 @@ const sockend = new cote.Sockend(io, {
     // key: 'a certain key'
 });
 ```
-
 Now, fire up a few `Responder`s and `Publisher`s (from the `examples` folder)
 on default or 'rnd' namespace and watch them glow with magic on
 `http://localhost:5555`.
 
+##### Socket.io Rooms
+`Sockend` supports socket.io rooms. All you need to do is add a `__rooms` or `__room` attribute to
+the published message.
+
+```js
+const randomPublisher = new cote.Publisher({
+    name: 'Random Publisher',
+    // namespace: 'rnd',
+    // key: 'a certain key',
+    broadcasts: ['randomUpdate'],
+});
+
+randomPublisher.publish('randomUpdate', { val: 500, __rooms: ['room1', 'room2'] });
+randomPublisher.publish('randomUpdate', { val: 500, __room: 'room1' });
+```
+
 ### Monitor
 
 Monitor is the "top" of cote. It lists all the daemons it discovers regardless
@@ -883,12 +906,12 @@ const cote = require('cote');
 
 const purchaseRequester = new cote.Requester({
     name: 'Purchase Requester',
-    key: 'purchase'
+    key: 'purchase',
 });
 
 const inventoryRequester = new cote.Requester({
     name: 'Inventory Requester',
-    key: 'inventory'
+    key: 'inventory',
 });
 ```
 
@@ -921,12 +944,12 @@ const cote = require('cote');
 
 const responder = new cote.Responder({
     name: 'Conversion Sockend Responder',
-    namespace: 'conversion'
+    namespace: 'conversion',
 });
 
 const conversionRequester = new cote.Requester({
     name: 'Conversion Requester',
-    key: 'conversion backend'
+    key: 'conversion backend',
 });
 
 responder.on('convert', (req, cb) => {
@@ -941,7 +964,7 @@ const cote = require('cote');
 
 const responder = new cote.Responder({
     name: 'Conversion Responder',
-    key: 'conversion backend'
+    key: 'conversion backend',
 });
 
 const rates = { usd_eur: 0.91, eur_usd: 1.10 };
@@ -1078,7 +1101,7 @@ accomodate different solutions that can serve as the automated service
 discovery tool. Currently, redis is supported out of the box, and cote
 makes use of the [node_redis](https://github.com/NodeRedis/node_redis)
 library, in case you want to use redis as the central discovery tool. If you
-need to use anything other than redis, please open 
+need to use anything other than redis, please open
 [a new issue](https://github.com/dashersw/cote/issues/new) and we may be
 able to help.
 
@@ -1092,7 +1115,7 @@ container deployment configurations such as Docker Swarm stack definitions
 can make use of the additional redis backend functionality, while developers
 can still use IP broadcast/multicast locally, with the same source code.
 
-That's why cote uses environment variables that start with 
+That's why cote uses environment variables that start with
 `COTE_DISCOVERY_REDIS`. cote transforms any environment variable that
 starts with `COTE_DISCOVERY_REDIS` to proper configuration for the
 [node_redis](https://github.com/NodeRedis/node_redis) library. For example,
diff --git a/dist/components/publisher.js b/dist/components/publisher.js
index 99c8a09..79cba09 100644
--- a/dist/components/publisher.js
+++ b/dist/components/publisher.js
@@ -52,10 +52,11 @@ module.exports = function (_Configurable) {
         value: function publish(topic, data) {
             var namespace = '';
 
-            if (this.advertisement.namespace) namespace = this.advertisement.namespace + '::';
+            if (this.advertisement.namespace) {
+                namespace = this.advertisement.namespace + '::';
+            }
 
             topic = 'message::' + namespace + topic;
-
             this.sock.emit(topic, data);
         }
     }, {
diff --git a/dist/components/publisher.js.map b/dist/components/publisher.js.map
index 6ab796d..7e7d0f5 100644
--- a/dist/components/publisher.js.map
+++ b/dist/components/publisher.js.map
@@ -1 +1 @@
-{"version":3,"sources":["../../src/components/publisher.js"],"names":["Configurable","require","Component","axon","portfinder","module","exports","advertisement","discoveryOptions","sock","types","type","on","startDiscovery","onPort","err","port","bind","server","code","getPort","host","address","topic","data","namespace","emit"],"mappings":";;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,gBAAR,CAArB;AACA,IAAMC,YAAYD,QAAQ,aAAR,CAAlB;AACA,IAAME,OAAOF,QAAQ,gBAAR,CAAb;AACA,IAAMG,aAAaH,QAAQ,YAAR,CAAnB;;AAEAI,OAAOC,OAAP;AAAA;;AACI,uBAAYC,aAAZ,EAA2BC,gBAA3B,EAA6C;AAAA;;AAAA,0HACnCD,aADmC,EACpBC,gBADoB;;AAGzC,cAAKC,IAAL,GAAY,IAAIN,KAAKO,KAAL,CAAW,MAAKC,IAAhB,CAAJ,EAAZ;AACA,cAAKF,IAAL,CAAUA,IAAV,CAAeG,EAAf,CAAkB,MAAlB,EAA0B;AAAA,mBAAM,MAAKC,cAAL,EAAN;AAAA,SAA1B;;AAEA,YAAMC,SAAS,SAATA,MAAS,CAACC,GAAD,EAAMC,IAAN,EAAe;AAC1B,kBAAKT,aAAL,CAAmBS,IAAnB,GAA0B,CAACA,IAA3B;;AAEA,kBAAKP,IAAL,CAAUQ,IAAV,CAAeD,IAAf;AACA,kBAAKP,IAAL,CAAUA,IAAV,CAAeS,MAAf,CAAsBN,EAAtB,CAAyB,OAAzB,EAAkC,UAACG,GAAD,EAAS;AACvC,oBAAIA,IAAII,IAAJ,IAAY,YAAhB,EAA8B,MAAMJ,GAAN;;AAE9BX,2BAAWgB,OAAX,CAAmB;AACfC,0BAAM,MAAKb,gBAAL,CAAsBc,OADb;AAEfN,0BAAM,MAAKT,aAAL,CAAmBS;AAFV,iBAAnB,EAGGF,MAHH;AAIH,aAPD;AAQH,SAZD;;AAcAV,mBAAWgB,OAAX,CAAmB;AACfC,kBAAM,MAAKb,gBAAL,CAAsBc,OADb;AAEfN,kBAAMT,cAAcS;AAFL,SAAnB,EAGGF,MAHH;AApByC;AAwB5C;;AAzBL;AAAA;AAAA,gCA2BYS,KA3BZ,EA2BmBC,IA3BnB,EA2ByB;AACjB,gBAAIC,YAAY,EAAhB;;AAEA,gBAAI,KAAKlB,aAAL,CAAmBkB,SAAvB,EACIA,YAAY,KAAKlB,aAAL,CAAmBkB,SAAnB,GAA+B,IAA3C;;AAEJF,oBAAQ,cAAcE,SAAd,GAA0BF,KAAlC;;AAEA,iBAAKd,IAAL,CAAUiB,IAAV,CAAeH,KAAf,EAAsBC,IAAtB;AACH;AApCL;AAAA;AAAA,4BAsCe;AACP,mBAAO,aAAP;AACH;AAxCL;AAAA;AAAA,4BAyCe;AACP,mBAAO,aAAP;AACH;AA3CL;;AAAA;AAAA,EAAyCxB,aAAaE,SAAb,CAAzC","file":"publisher.js","sourcesContent":["const Configurable = require('./configurable');\nconst Component = require('./component');\nconst axon = require('@dashersw/axon');\nconst portfinder = require('portfinder');\n\nmodule.exports = class Publisher extends Configurable(Component) {\n    constructor(advertisement, discoveryOptions) {\n        super(advertisement, discoveryOptions);\n\n        this.sock = new axon.types[this.type]();\n        this.sock.sock.on('bind', () => this.startDiscovery());\n\n        const onPort = (err, port) => {\n            this.advertisement.port = +port;\n\n            this.sock.bind(port);\n            this.sock.sock.server.on('error', (err) => {\n                if (err.code != 'EADDRINUSE') throw err;\n\n                portfinder.getPort({\n                    host: this.discoveryOptions.address,\n                    port: this.advertisement.port,\n                }, onPort);\n            });\n        };\n\n        portfinder.getPort({\n            host: this.discoveryOptions.address,\n            port: advertisement.port,\n        }, onPort);\n    }\n\n    publish(topic, data) {\n        let namespace = '';\n\n        if (this.advertisement.namespace)\n            namespace = this.advertisement.namespace + '::';\n\n        topic = 'message::' + namespace + topic;\n\n        this.sock.emit(topic, data);\n    };\n\n    get type() {\n        return 'pub-emitter';\n    }\n    get oppo() {\n        return 'sub-emitter';\n    }\n};\n"]}
\ No newline at end of file
+{"version":3,"sources":["../../src/components/publisher.js"],"names":["Configurable","require","Component","axon","portfinder","module","exports","advertisement","discoveryOptions","sock","types","type","on","startDiscovery","onPort","err","port","bind","server","code","getPort","host","address","topic","data","namespace","emit"],"mappings":";;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,gBAAR,CAArB;AACA,IAAMC,YAAYD,QAAQ,aAAR,CAAlB;AACA,IAAME,OAAOF,QAAQ,gBAAR,CAAb;AACA,IAAMG,aAAaH,QAAQ,YAAR,CAAnB;;AAEAI,OAAOC,OAAP;AAAA;;AACI,uBAAYC,aAAZ,EAA2BC,gBAA3B,EAA6C;AAAA;;AAAA,0HACnCD,aADmC,EACpBC,gBADoB;;AAGzC,cAAKC,IAAL,GAAY,IAAIN,KAAKO,KAAL,CAAW,MAAKC,IAAhB,CAAJ,EAAZ;AACA,cAAKF,IAAL,CAAUA,IAAV,CAAeG,EAAf,CAAkB,MAAlB,EAA0B;AAAA,mBAAM,MAAKC,cAAL,EAAN;AAAA,SAA1B;;AAEA,YAAMC,SAAS,SAATA,MAAS,CAACC,GAAD,EAAMC,IAAN,EAAe;AAC1B,kBAAKT,aAAL,CAAmBS,IAAnB,GAA0B,CAACA,IAA3B;;AAEA,kBAAKP,IAAL,CAAUQ,IAAV,CAAeD,IAAf;AACA,kBAAKP,IAAL,CAAUA,IAAV,CAAeS,MAAf,CAAsBN,EAAtB,CAAyB,OAAzB,EAAkC,UAACG,GAAD,EAAS;AACvC,oBAAIA,IAAII,IAAJ,IAAY,YAAhB,EAA8B,MAAMJ,GAAN;;AAE9BX,2BAAWgB,OAAX,CAAmB;AACfC,0BAAM,MAAKb,gBAAL,CAAsBc,OADb;AAEfN,0BAAM,MAAKT,aAAL,CAAmBS;AAFV,iBAAnB,EAGGF,MAHH;AAIH,aAPD;AAQH,SAZD;;AAcAV,mBAAWgB,OAAX,CAAmB;AACfC,kBAAM,MAAKb,gBAAL,CAAsBc,OADb;AAEfN,kBAAMT,cAAcS;AAFL,SAAnB,EAGGF,MAHH;AApByC;AAwB5C;;AAzBL;AAAA;AAAA,gCA2BYS,KA3BZ,EA2BmBC,IA3BnB,EA2ByB;AACjB,gBAAIC,YAAY,EAAhB;;AAEA,gBAAI,KAAKlB,aAAL,CAAmBkB,SAAvB,EAAkC;AAC9BA,4BAAY,KAAKlB,aAAL,CAAmBkB,SAAnB,GAA+B,IAA3C;AACH;;AAEDF,oBAAQ,cAAcE,SAAd,GAA0BF,KAAlC;AACA,iBAAKd,IAAL,CAAUiB,IAAV,CAAeH,KAAf,EAAsBC,IAAtB;AACH;AApCL;AAAA;AAAA,4BAsCe;AACP,mBAAO,aAAP;AACH;AAxCL;AAAA;AAAA,4BA0Ce;AACP,mBAAO,aAAP;AACH;AA5CL;;AAAA;AAAA,EAAyCxB,aAAaE,SAAb,CAAzC","file":"publisher.js","sourcesContent":["const Configurable = require('./configurable');\nconst Component = require('./component');\nconst axon = require('@dashersw/axon');\nconst portfinder = require('portfinder');\n\nmodule.exports = class Publisher extends Configurable(Component) {\n    constructor(advertisement, discoveryOptions) {\n        super(advertisement, discoveryOptions);\n\n        this.sock = new axon.types[this.type]();\n        this.sock.sock.on('bind', () => this.startDiscovery());\n\n        const onPort = (err, port) => {\n            this.advertisement.port = +port;\n\n            this.sock.bind(port);\n            this.sock.sock.server.on('error', (err) => {\n                if (err.code != 'EADDRINUSE') throw err;\n\n                portfinder.getPort({\n                    host: this.discoveryOptions.address,\n                    port: this.advertisement.port,\n                }, onPort);\n            });\n        };\n\n        portfinder.getPort({\n            host: this.discoveryOptions.address,\n            port: advertisement.port,\n        }, onPort);\n    }\n\n    publish(topic, data) {\n        let namespace = '';\n\n        if (this.advertisement.namespace) {\n            namespace = this.advertisement.namespace + '::';\n        }\n\n        topic = 'message::' + namespace + topic;\n        this.sock.emit(topic, data);\n    };\n\n    get type() {\n        return 'pub-emitter';\n    }\n\n    get oppo() {\n        return 'sub-emitter';\n    }\n};\n"]}
\ No newline at end of file
diff --git a/dist/components/sockend.js b/dist/components/sockend.js
index 7208fa5..c4ba282 100644
--- a/dist/components/sockend.js
+++ b/dist/components/sockend.js
@@ -117,15 +117,27 @@ module.exports = function (_Configurable) {
 
                 var topic = this.event.split('::');
                 var namespace = '';
-
                 if (topic.length > 1) {
                     namespace += '/' + topic[0];
                     topic = topic.slice(1);
                 }
-
                 topic = topic.join('');
 
-                io.of(namespace).emit(topic, data);
+                var emitter = io.of(namespace);
+                if (data.__room) {
+                    data.__rooms = new Set(data.__rooms || []);
+                    data.__rooms.add(data.__room);
+                    delete data.__room;
+                }
+                if (data.__rooms) {
+                    var rooms = data.__rooms;
+                    delete data.__rooms;
+                    rooms.forEach(function (room) {
+                        emitter.to(room).emit(topic, data);
+                    });
+                } else {
+                    emitter.emit(topic, data);
+                }
             });
         });
         return _this;
diff --git a/dist/components/sockend.js.map b/dist/components/sockend.js.map
index e51d33a..b1f49f1 100644
--- a/dist/components/sockend.js.map
+++ b/dist/components/sockend.js.map
@@ -1 +1 @@
-{"version":3,"sources":["../../src/components/sockend.js"],"names":["EventEmitter","require","EventEmitter2","util","Discovery","axon","Subscriber","Requester","Configurable","Component","module","exports","io","advertisement","discoveryOptions","originalKey","key","requesterTransformators","startDiscovery","namespaces","discovery","on","obj","axon_type","Array","isArray","respondsTo","namespace","normalizedNamespace","requester","name","originalRequestOnAdded","onAdded","bind","requesterSocketHandler","socket","forEach","topic","data","cb","type","transFn","send","server","of","sId","sockets","publisherNamespaces","subscriber","subscribesTo","broadcasts","onMonitorAdded","event","split","length","slice","join","emit"],"mappings":";;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,eAAR,EAAyBC,aAA9C;AACA,IAAMC,OAAOF,QAAQ,MAAR,CAAb;AACA,IAAMG,YAAYH,QAAQ,aAAR,CAAlB;AACA,IAAMI,OAAOJ,QAAQ,gBAAR,CAAb;AACA,IAAMK,aAAaL,QAAQ,cAAR,CAAnB;AACA,IAAMM,YAAYN,QAAQ,aAAR,CAAlB;AACA,IAAMO,eAAeP,QAAQ,gBAAR,CAArB;AACA,IAAMQ,YAAYR,QAAQ,aAAR,CAAlB;;AAEAS,OAAOC,OAAP;AAAA;;AACI,qBAAYC,EAAZ,EAAgBC,aAAhB,EAA+BC,gBAA/B,EAAiD;AAAA;;AAC7C,YAAMC,cAAcF,cAAcG,GAAlC;;AAD6C,sHAEvCH,aAFuC,EAExBC,gBAFwB;;AAI7C,cAAKG,uBAAL,GAA+B,EAA/B;;AAEA,cAAKC,cAAL;;AAEA,YAAMC,aAAa,EAAnB;;AAEA,cAAKC,SAAL,CAAeC,EAAf,CAAkB,OAAlB,EAA2B,UAACC,GAAD,EAAS;AAChC,gBAAIA,IAAIT,aAAJ,CAAkBU,SAAlB,IAA+B,KAAnC,EAA0C;AAC1C,gBAAID,IAAIT,aAAJ,CAAkBG,GAAlB,IAAyB,MAAKH,aAAL,CAAmBG,GAAhD,EAAqD;AACrD,gBAAI,CAACQ,MAAMC,OAAN,CAAcH,IAAIT,aAAJ,CAAkBa,UAAhC,CAAL,EAAkD;;AAElD,gBAAMC,YAAYL,IAAIT,aAAJ,CAAkBc,SAApC;AACA,gBAAMC,sBAAsBD,aAAa,EAAzC;;AAEA,gBAAIR,WAAW,MAAMS,mBAAjB,CAAJ,EAA2C;;AAE3CT,uBAAW,MAAMS,mBAAjB,IAAwC,IAAxC;AACAN,gBAAIK,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAME,YAAY,IAAItB,SAAJ,CAAc;AAC5BuB,sBAAM,YADsB;AAE5BH,oCAF4B;AAG5BX,qBAAKD;AAHuB,aAAd,EAIfD,gBAJe,CAAlB;AAKAQ,gBAAIO,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAME,yBAAyBF,UAAUG,OAAV,CAAkBC,IAAlB,CAAuBJ,SAAvB,CAA/B;AACAA,sBAAUG,OAAV,GAAoB,UAACV,GAAD,EAAS;AACzB,oBAAI,CAACE,MAAMC,OAAN,CAAcH,IAAIT,aAAJ,CAAkBa,UAAhC,CAAL,EAAkD;AAClDK,uCAAuBT,GAAvB;AACH,aAHD;;AAKAA,gBAAIY,sBAAJ,GAA6B,UAACC,MAAD,EAAY;AACrCb,oBAAIT,aAAJ,CAAkBa,UAAlB,CAA6BU,OAA7B,CAAqC,UAACC,KAAD,EAAW;AAC5CF,2BAAOd,EAAP,CAAUgB,KAAV,EAAiB,UAACC,IAAD,EAAOC,EAAP,EAAc;AAC3B,4BAAI,OAAOD,IAAP,IAAe,UAAf,IAA6B,OAAOC,EAAP,IAAa,WAA9C,EAA2D;AACvDA,iCAAKD,IAAL;AACAA,mCAAO,EAAP;AACH;;AAEDA,6BAAKE,IAAL,GAAYH,KAAZ;;AAEA,8BAAKpB,uBAAL,CAA6BmB,OAA7B,CAAqC,UAACK,OAAD;AAAA,mCAAaA,QAAQH,IAAR,EAAcH,MAAd,CAAb;AAAA,yBAArC;;AAEAN,kCAAUa,IAAV,CAAeJ,IAAf,EAAqBC,EAArB;AACH,qBAXD;AAYH,iBAbD;AAcH,aAfD;;AAiBA,gBAAII,SAAS/B,GAAGgC,EAAH,CAAM,GAAN,CAAb;AACA,gBAAIjB,SAAJ,EAAegB,SAAS/B,GAAGgC,EAAH,CAAM,MAAMjB,SAAZ,CAAT;AACfgB,mBAAOtB,EAAP,CAAU,YAAV,EAAwBC,IAAIY,sBAA5B;;AAEA,iBAAK,IAAIW,GAAT,IAAgBF,OAAOG,OAAvB,EAAgC;AAC5BxB,oBAAIY,sBAAJ,CAA2BS,OAAOG,OAAP,CAAeD,GAAf,CAA3B;AACH;AACJ,SAlDD;;AAoDA,YAAME,sBAAsB,EAA5B;;AAEA,cAAK3B,SAAL,CAAeC,EAAf,CAAkB,OAAlB,EAA2B,UAACC,GAAD,EAAS;AAChC,gBAAIA,IAAIT,aAAJ,CAAkBU,SAAlB,IAA+B,aAAnC,EAAkD;AAClD,gBAAID,IAAIT,aAAJ,CAAkBG,GAAlB,IAAyB,MAAKH,aAAL,CAAmBG,GAAhD,EAAqD;;AAErD,gBAAMW,YAAYL,IAAIT,aAAJ,CAAkBc,SAApC;AACA,gBAAMC,sBAAsBD,aAAa,EAAzC;;AAEA,gBAAIoB,oBAAoB,MAAMnB,mBAA1B,CAAJ,EAAoD;;AAEpDmB,gCAAoB,MAAMnB,mBAA1B,IAAiD,IAAjD;AACAN,gBAAIK,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAMqB,aAAa,IAAI1C,UAAJ,CAAe;AAC9BwB,sBAAM,YADwB;AAE9BH,2BAAWA,SAFmB;AAG9BX,qBAAKD,WAHyB;AAI9BkC,8BAAc3B,IAAIT,aAAJ,CAAkBqC;AAJF,aAAf,EAKhBpC,gBALgB,CAAnB;;AAOAkC,uBAAWG,cAAX,GAA4B,YAAM,CAAG,CAArC;;AAEA7B,gBAAI0B,UAAJ,GAAiBA,UAAjB;;AAEAA,uBAAW3B,EAAX,CAAc,IAAd,EAAoB,UAASiB,IAAT,EAAe;AAC/B,oBAAI,KAAKc,KAAL,IAAc,YAAd,IAA8B,KAAKA,KAAL,IAAc,cAAhD,EAAgE;;AAEhE,oBAAIf,QAAQ,KAAKe,KAAL,CAAWC,KAAX,CAAiB,IAAjB,CAAZ;AACA,oBAAI1B,YAAY,EAAhB;;AAEA,oBAAIU,MAAMiB,MAAN,GAAe,CAAnB,EAAsB;AAClB3B,iCAAa,MAAMU,MAAM,CAAN,CAAnB;AACAA,4BAAQA,MAAMkB,KAAN,CAAY,CAAZ,CAAR;AACH;;AAEDlB,wBAAQA,MAAMmB,IAAN,CAAW,EAAX,CAAR;;AAEA5C,mBAAGgC,EAAH,CAAMjB,SAAN,EAAiB8B,IAAjB,CAAsBpB,KAAtB,EAA6BC,IAA7B;AACH,aAdD;AAeH,SAtCD;AAhE6C;AAuGhD;;AAxGL;AAAA;AAAA,4BA0Ge;AACP,mBAAO,SAAP;AACH;AA5GL;;AAAA;AAAA,EAAuC9B,aAAaC,SAAb,CAAvC","file":"sockend.js","sourcesContent":["const EventEmitter = require('eventemitter2').EventEmitter2;\nconst util = require('util');\nconst Discovery = require('./discovery');\nconst axon = require('@dashersw/axon');\nconst Subscriber = require('./subscriber');\nconst Requester = require('./requester');\nconst Configurable = require('./configurable');\nconst Component = require('./component');\n\nmodule.exports = class Sockend extends Configurable(Component) {\n    constructor(io, advertisement, discoveryOptions) {\n        const originalKey = advertisement.key;\n        super(advertisement, discoveryOptions);\n\n        this.requesterTransformators = [];\n\n        this.startDiscovery();\n\n        const namespaces = {};\n\n        this.discovery.on('added', (obj) => {\n            if (obj.advertisement.axon_type != 'rep') return;\n            if (obj.advertisement.key != this.advertisement.key) return;\n            if (!Array.isArray(obj.advertisement.respondsTo)) return;\n\n            const namespace = obj.advertisement.namespace;\n            const normalizedNamespace = namespace || '';\n\n            if (namespaces['/' + normalizedNamespace]) return;\n\n            namespaces['/' + normalizedNamespace] = true;\n            obj.namespace = namespace;\n\n            const requester = new Requester({\n                name: 'sockendReq',\n                namespace,\n                key: originalKey,\n            }, discoveryOptions);\n            obj.requester = requester;\n\n            const originalRequestOnAdded = requester.onAdded.bind(requester);\n            requester.onAdded = (obj) => {\n                if (!Array.isArray(obj.advertisement.respondsTo)) return;\n                originalRequestOnAdded(obj);\n            };\n\n            obj.requesterSocketHandler = (socket) => {\n                obj.advertisement.respondsTo.forEach((topic) => {\n                    socket.on(topic, (data, cb) => {\n                        if (typeof data == 'function' && typeof cb == 'undefined') {\n                            cb = data;\n                            data = {};\n                        }\n\n                        data.type = topic;\n\n                        this.requesterTransformators.forEach((transFn) => transFn(data, socket));\n\n                        requester.send(data, cb);\n                    });\n                });\n            };\n\n            let server = io.of('/');\n            if (namespace) server = io.of('/' + namespace);\n            server.on('connection', obj.requesterSocketHandler);\n\n            for (let sId in server.sockets) {\n                obj.requesterSocketHandler(server.sockets[sId]);\n            }\n        });\n\n        const publisherNamespaces = {};\n\n        this.discovery.on('added', (obj) => {\n            if (obj.advertisement.axon_type != 'pub-emitter') return;\n            if (obj.advertisement.key != this.advertisement.key) return;\n\n            const namespace = obj.advertisement.namespace;\n            const normalizedNamespace = namespace || '';\n\n            if (publisherNamespaces['/' + normalizedNamespace]) return;\n\n            publisherNamespaces['/' + normalizedNamespace] = true;\n            obj.namespace = namespace;\n\n            const subscriber = new Subscriber({\n                name: 'sockendSub',\n                namespace: namespace,\n                key: originalKey,\n                subscribesTo: obj.advertisement.broadcasts,\n            }, discoveryOptions);\n\n            subscriber.onMonitorAdded = () => { };\n\n            obj.subscriber = subscriber;\n\n            subscriber.on('**', function(data) {\n                if (this.event == 'cote:added' || this.event == 'cote:removed') return;\n\n                let topic = this.event.split('::');\n                let namespace = '';\n\n                if (topic.length > 1) {\n                    namespace += '/' + topic[0];\n                    topic = topic.slice(1);\n                }\n\n                topic = topic.join('');\n\n                io.of(namespace).emit(topic, data);\n            });\n        });\n    };\n\n    get type() {\n        return 'sockend';\n    }\n};\n"]}
\ No newline at end of file
+{"version":3,"sources":["../../src/components/sockend.js"],"names":["EventEmitter","require","EventEmitter2","util","Discovery","axon","Subscriber","Requester","Configurable","Component","module","exports","io","advertisement","discoveryOptions","originalKey","key","requesterTransformators","startDiscovery","namespaces","discovery","on","obj","axon_type","Array","isArray","respondsTo","namespace","normalizedNamespace","requester","name","originalRequestOnAdded","onAdded","bind","requesterSocketHandler","socket","forEach","topic","data","cb","type","transFn","send","server","of","sId","sockets","publisherNamespaces","subscriber","subscribesTo","broadcasts","onMonitorAdded","event","split","length","slice","join","emitter","__room","__rooms","Set","add","rooms","room","to","emit"],"mappings":";;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,eAAR,EAAyBC,aAA9C;AACA,IAAMC,OAAOF,QAAQ,MAAR,CAAb;AACA,IAAMG,YAAYH,QAAQ,aAAR,CAAlB;AACA,IAAMI,OAAOJ,QAAQ,gBAAR,CAAb;AACA,IAAMK,aAAaL,QAAQ,cAAR,CAAnB;AACA,IAAMM,YAAYN,QAAQ,aAAR,CAAlB;AACA,IAAMO,eAAeP,QAAQ,gBAAR,CAArB;AACA,IAAMQ,YAAYR,QAAQ,aAAR,CAAlB;;AAEAS,OAAOC,OAAP;AAAA;;AACI,qBAAYC,EAAZ,EAAgBC,aAAhB,EAA+BC,gBAA/B,EAAiD;AAAA;;AAC7C,YAAMC,cAAcF,cAAcG,GAAlC;;AAD6C,sHAEvCH,aAFuC,EAExBC,gBAFwB;;AAI7C,cAAKG,uBAAL,GAA+B,EAA/B;;AAEA,cAAKC,cAAL;;AAEA,YAAMC,aAAa,EAAnB;;AAEA,cAAKC,SAAL,CAAeC,EAAf,CAAkB,OAAlB,EAA2B,UAACC,GAAD,EAAS;AAChC,gBAAIA,IAAIT,aAAJ,CAAkBU,SAAlB,IAA+B,KAAnC,EAA0C;AAC1C,gBAAID,IAAIT,aAAJ,CAAkBG,GAAlB,IAAyB,MAAKH,aAAL,CAAmBG,GAAhD,EAAqD;AACrD,gBAAI,CAACQ,MAAMC,OAAN,CAAcH,IAAIT,aAAJ,CAAkBa,UAAhC,CAAL,EAAkD;;AAElD,gBAAMC,YAAYL,IAAIT,aAAJ,CAAkBc,SAApC;AACA,gBAAMC,sBAAsBD,aAAa,EAAzC;;AAEA,gBAAIR,WAAW,MAAMS,mBAAjB,CAAJ,EAA2C;;AAE3CT,uBAAW,MAAMS,mBAAjB,IAAwC,IAAxC;AACAN,gBAAIK,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAME,YAAY,IAAItB,SAAJ,CAAc;AAC5BuB,sBAAM,YADsB;AAE5BH,oCAF4B;AAG5BX,qBAAKD;AAHuB,aAAd,EAIfD,gBAJe,CAAlB;AAKAQ,gBAAIO,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAME,yBAAyBF,UAAUG,OAAV,CAAkBC,IAAlB,CAAuBJ,SAAvB,CAA/B;AACAA,sBAAUG,OAAV,GAAoB,UAACV,GAAD,EAAS;AACzB,oBAAI,CAACE,MAAMC,OAAN,CAAcH,IAAIT,aAAJ,CAAkBa,UAAhC,CAAL,EAAkD;AAClDK,uCAAuBT,GAAvB;AACH,aAHD;;AAKAA,gBAAIY,sBAAJ,GAA6B,UAACC,MAAD,EAAY;AACrCb,oBAAIT,aAAJ,CAAkBa,UAAlB,CAA6BU,OAA7B,CAAqC,UAACC,KAAD,EAAW;AAC5CF,2BAAOd,EAAP,CAAUgB,KAAV,EAAiB,UAACC,IAAD,EAAOC,EAAP,EAAc;AAC3B,4BAAI,OAAOD,IAAP,IAAe,UAAf,IAA6B,OAAOC,EAAP,IAAa,WAA9C,EAA2D;AACvDA,iCAAKD,IAAL;AACAA,mCAAO,EAAP;AACH;;AAEDA,6BAAKE,IAAL,GAAYH,KAAZ;;AAEA,8BAAKpB,uBAAL,CAA6BmB,OAA7B,CAAqC,UAACK,OAAD;AAAA,mCAAaA,QAAQH,IAAR,EAAcH,MAAd,CAAb;AAAA,yBAArC;;AAEAN,kCAAUa,IAAV,CAAeJ,IAAf,EAAqBC,EAArB;AACH,qBAXD;AAYH,iBAbD;AAcH,aAfD;;AAiBA,gBAAII,SAAS/B,GAAGgC,EAAH,CAAM,GAAN,CAAb;AACA,gBAAIjB,SAAJ,EAAegB,SAAS/B,GAAGgC,EAAH,CAAM,MAAMjB,SAAZ,CAAT;AACfgB,mBAAOtB,EAAP,CAAU,YAAV,EAAwBC,IAAIY,sBAA5B;;AAEA,iBAAK,IAAIW,GAAT,IAAgBF,OAAOG,OAAvB,EAAgC;AAC5BxB,oBAAIY,sBAAJ,CAA2BS,OAAOG,OAAP,CAAeD,GAAf,CAA3B;AACH;AACJ,SAlDD;;AAoDA,YAAME,sBAAsB,EAA5B;;AAEA,cAAK3B,SAAL,CAAeC,EAAf,CAAkB,OAAlB,EAA2B,UAACC,GAAD,EAAS;AAChC,gBAAIA,IAAIT,aAAJ,CAAkBU,SAAlB,IAA+B,aAAnC,EAAkD;AAClD,gBAAID,IAAIT,aAAJ,CAAkBG,GAAlB,IAAyB,MAAKH,aAAL,CAAmBG,GAAhD,EAAqD;;AAErD,gBAAMW,YAAYL,IAAIT,aAAJ,CAAkBc,SAApC;AACA,gBAAMC,sBAAsBD,aAAa,EAAzC;;AAEA,gBAAIoB,oBAAoB,MAAMnB,mBAA1B,CAAJ,EAAoD;;AAEpDmB,gCAAoB,MAAMnB,mBAA1B,IAAiD,IAAjD;AACAN,gBAAIK,SAAJ,GAAgBA,SAAhB;;AAEA,gBAAMqB,aAAa,IAAI1C,UAAJ,CAAe;AAC9BwB,sBAAM,YADwB;AAE9BH,2BAAWA,SAFmB;AAG9BX,qBAAKD,WAHyB;AAI9BkC,8BAAc3B,IAAIT,aAAJ,CAAkBqC;AAJF,aAAf,EAKhBpC,gBALgB,CAAnB;;AAOAkC,uBAAWG,cAAX,GAA4B,YAAM,CACjC,CADD;;AAGA7B,gBAAI0B,UAAJ,GAAiBA,UAAjB;;AAEAA,uBAAW3B,EAAX,CAAc,IAAd,EAAoB,UAAUiB,IAAV,EAAgB;AAChC,oBAAI,KAAKc,KAAL,IAAc,YAAd,IAA8B,KAAKA,KAAL,IAAc,cAAhD,EAAgE;;AAEhE,oBAAIf,QAAQ,KAAKe,KAAL,CAAWC,KAAX,CAAiB,IAAjB,CAAZ;AACA,oBAAI1B,YAAY,EAAhB;AACA,oBAAIU,MAAMiB,MAAN,GAAe,CAAnB,EAAsB;AAClB3B,iCAAa,MAAMU,MAAM,CAAN,CAAnB;AACAA,4BAAQA,MAAMkB,KAAN,CAAY,CAAZ,CAAR;AACH;AACDlB,wBAAQA,MAAMmB,IAAN,CAAW,EAAX,CAAR;;AAEA,oBAAIC,UAAU7C,GAAGgC,EAAH,CAAMjB,SAAN,CAAd;AACA,oBAAIW,KAAKoB,MAAT,EAAiB;AACbpB,yBAAKqB,OAAL,GAAe,IAAIC,GAAJ,CAAQtB,KAAKqB,OAAL,IAAgB,EAAxB,CAAf;AACArB,yBAAKqB,OAAL,CAAaE,GAAb,CAAiBvB,KAAKoB,MAAtB;AACA,2BAAOpB,KAAKoB,MAAZ;AACH;AACD,oBAAIpB,KAAKqB,OAAT,EAAkB;AACd,wBAAMG,QAAQxB,KAAKqB,OAAnB;AACA,2BAAOrB,KAAKqB,OAAZ;AACAG,0BAAM1B,OAAN,CAAc,UAAC2B,IAAD,EAAU;AACpBN,gCAAQO,EAAR,CAAWD,IAAX,EAAiBE,IAAjB,CAAsB5B,KAAtB,EAA6BC,IAA7B;AACH,qBAFD;AAGH,iBAND,MAMO;AACHmB,4BAAQQ,IAAR,CAAa5B,KAAb,EAAoBC,IAApB;AACH;AACJ,aA1BD;AA2BH,SAnDD;AAhE6C;AAoHhD;;AArHL;AAAA;AAAA,4BAuHe;AACP,mBAAO,SAAP;AACH;AAzHL;;AAAA;AAAA,EAAuC9B,aAAaC,SAAb,CAAvC","file":"sockend.js","sourcesContent":["const EventEmitter = require('eventemitter2').EventEmitter2;\nconst util = require('util');\nconst Discovery = require('./discovery');\nconst axon = require('@dashersw/axon');\nconst Subscriber = require('./subscriber');\nconst Requester = require('./requester');\nconst Configurable = require('./configurable');\nconst Component = require('./component');\n\nmodule.exports = class Sockend extends Configurable(Component) {\n    constructor(io, advertisement, discoveryOptions) {\n        const originalKey = advertisement.key;\n        super(advertisement, discoveryOptions);\n\n        this.requesterTransformators = [];\n\n        this.startDiscovery();\n\n        const namespaces = {};\n\n        this.discovery.on('added', (obj) => {\n            if (obj.advertisement.axon_type != 'rep') return;\n            if (obj.advertisement.key != this.advertisement.key) return;\n            if (!Array.isArray(obj.advertisement.respondsTo)) return;\n\n            const namespace = obj.advertisement.namespace;\n            const normalizedNamespace = namespace || '';\n\n            if (namespaces['/' + normalizedNamespace]) return;\n\n            namespaces['/' + normalizedNamespace] = true;\n            obj.namespace = namespace;\n\n            const requester = new Requester({\n                name: 'sockendReq',\n                namespace,\n                key: originalKey,\n            }, discoveryOptions);\n            obj.requester = requester;\n\n            const originalRequestOnAdded = requester.onAdded.bind(requester);\n            requester.onAdded = (obj) => {\n                if (!Array.isArray(obj.advertisement.respondsTo)) return;\n                originalRequestOnAdded(obj);\n            };\n\n            obj.requesterSocketHandler = (socket) => {\n                obj.advertisement.respondsTo.forEach((topic) => {\n                    socket.on(topic, (data, cb) => {\n                        if (typeof data == 'function' && typeof cb == 'undefined') {\n                            cb = data;\n                            data = {};\n                        }\n\n                        data.type = topic;\n\n                        this.requesterTransformators.forEach((transFn) => transFn(data, socket));\n\n                        requester.send(data, cb);\n                    });\n                });\n            };\n\n            let server = io.of('/');\n            if (namespace) server = io.of('/' + namespace);\n            server.on('connection', obj.requesterSocketHandler);\n\n            for (let sId in server.sockets) {\n                obj.requesterSocketHandler(server.sockets[sId]);\n            }\n        });\n\n        const publisherNamespaces = {};\n\n        this.discovery.on('added', (obj) => {\n            if (obj.advertisement.axon_type != 'pub-emitter') return;\n            if (obj.advertisement.key != this.advertisement.key) return;\n\n            const namespace = obj.advertisement.namespace;\n            const normalizedNamespace = namespace || '';\n\n            if (publisherNamespaces['/' + normalizedNamespace]) return;\n\n            publisherNamespaces['/' + normalizedNamespace] = true;\n            obj.namespace = namespace;\n\n            const subscriber = new Subscriber({\n                name: 'sockendSub',\n                namespace: namespace,\n                key: originalKey,\n                subscribesTo: obj.advertisement.broadcasts,\n            }, discoveryOptions);\n\n            subscriber.onMonitorAdded = () => {\n            };\n\n            obj.subscriber = subscriber;\n\n            subscriber.on('**', function (data) {\n                if (this.event == 'cote:added' || this.event == 'cote:removed') return;\n\n                let topic = this.event.split('::');\n                let namespace = '';\n                if (topic.length > 1) {\n                    namespace += '/' + topic[0];\n                    topic = topic.slice(1);\n                }\n                topic = topic.join('');\n\n                let emitter = io.of(namespace);\n                if (data.__room) {\n                    data.__rooms = new Set(data.__rooms || []);\n                    data.__rooms.add(data.__room);\n                    delete data.__room;\n                }\n                if (data.__rooms) {\n                    const rooms = data.__rooms;\n                    delete data.__rooms;\n                    rooms.forEach((room) => {\n                        emitter.to(room).emit(topic, data);\n                    });\n                } else {\n                    emitter.emit(topic, data);\n                }\n            });\n        });\n    };\n\n    get type() {\n        return 'sockend';\n    }\n};\n"]}
\ No newline at end of file
diff --git a/dist/components/subscriber.js b/dist/components/subscriber.js
index 455f393..8aa0fc2 100644
--- a/dist/components/subscriber.js
+++ b/dist/components/subscriber.js
@@ -32,7 +32,9 @@ module.exports = function (_Monitorable) {
 
         _this.advertisement.subscribesTo.forEach(function (topic) {
             var namespace = '';
-            if (_this.advertisement.namespace) namespace = _this.advertisement.namespace + '::';
+            if (_this.advertisement.namespace) {
+                namespace = _this.advertisement.namespace + '::';
+            }
 
             topic = 'message::' + namespace + topic;
 
@@ -42,8 +44,11 @@ module.exports = function (_Monitorable) {
                         args[_key] = arguments[_key];
                     }
 
-                    if (args.length == 1) args.unshift(topic.substr(9));else args[0] = namespace + args[0];
-
+                    if (args.length == 1) {
+                        args.unshift(topic.substr(9));
+                    } else {
+                        args[0] = namespace + args[0];
+                    }
                     _this.emit.apply(_this, args);
                 });
             })(topic);
@@ -77,7 +82,9 @@ module.exports = function (_Monitorable) {
         key: 'formatTypeWithNamespace',
         value: function formatTypeWithNamespace(type) {
             var namespace = '';
-            if (this.advertisement.namespace) namespace = this.advertisement.namespace + '::';
+            if (this.advertisement.namespace) {
+                namespace = this.advertisement.namespace + '::';
+            }
 
             return namespace + type;
         }
diff --git a/dist/components/subscriber.js.map b/dist/components/subscriber.js.map
index 70d3e79..4d5d31f 100644
--- a/dist/components/subscriber.js.map
+++ b/dist/components/subscriber.js.map
@@ -1 +1 @@
-{"version":3,"sources":["../../src/components/subscriber.js"],"names":["Configurable","require","Monitorable","Component","axon","module","exports","advertisement","discoveryOptions","startDiscovery","sock","types","type","set","subscribesTo","forEach","topic","namespace","on","args","length","unshift","substr","emit","obj","address","constructor","useHostNames","hostName","alreadyConnected","socks","some","s","_host","remoteAddress","remotePort","port","connect","listener","formatTypeWithNamespace"],"mappings":";;;;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,gBAAR,CAArB;AACA,IAAMC,cAAcD,QAAQ,eAAR,CAApB;AACA,IAAME,YAAYF,QAAQ,aAAR,CAAlB;AACA,IAAMG,OAAOH,QAAQ,gBAAR,CAAb;;AAEAI,OAAOC,OAAP;AAAA;;AACI,wBAAYC,aAAZ,EAA2BC,gBAA3B,EAA6C;AAAA;;AAAA,4HACnCD,aADmC,EACpBC,gBADoB;;AAGzC,cAAKC,cAAL;;AAEA,cAAKC,IAAL,GAAY,IAAIN,KAAKO,KAAL,CAAW,MAAKC,IAAhB,CAAJ,EAAZ;AACA,cAAKF,IAAL,CAAUA,IAAV,CAAeG,GAAf,CAAmB,eAAnB,EAAoC,CAApC;;AAEA,cAAKN,aAAL,CAAmBO,YAAnB,GAAkC,MAAKP,aAAL,CAAmBO,YAAnB,IAAmC,CAAC,GAAD,CAArE;;AAEA,cAAKP,aAAL,CAAmBO,YAAnB,CAAgCC,OAAhC,CAAwC,UAACC,KAAD,EAAW;AAC/C,gBAAIC,YAAY,EAAhB;AACA,gBAAI,MAAKV,aAAL,CAAmBU,SAAvB,EACIA,YAAY,MAAKV,aAAL,CAAmBU,SAAnB,GAA+B,IAA3C;;AAEJD,oBAAQ,cAAcC,SAAd,GAA0BD,KAAlC;;AAEA,aAAC,UAACA,KAAD,EAAW;AACR,sBAAKN,IAAL,CAAUQ,EAAV,CAAaF,KAAb,EAAoB,YAAa;AAAA,sDAATG,IAAS;AAATA,4BAAS;AAAA;;AAC7B,wBAAIA,KAAKC,MAAL,IAAe,CAAnB,EACID,KAAKE,OAAL,CAAaL,MAAMM,MAAN,CAAa,CAAb,CAAb,EADJ,KAGIH,KAAK,CAAL,IAAUF,YAAYE,KAAK,CAAL,CAAtB;;AAEJ,0BAAKI,IAAL,cAAaJ,IAAb;AACH,iBAPD;AAQH,aATD,EASGH,KATH;AAUH,SAjBD;AAVyC;AA4B5C;;AA7BL;AAAA;AAAA,gCA+BYQ,GA/BZ,EA+BiB;AAAA;;AACT,4HAAcA,GAAd;;AAEA,gBAAMC,UAAU,KAAKC,WAAL,CAAiBC,YAAjB,GAAgCH,IAAII,QAApC,GAA+CJ,IAAIC,OAAnE;;AAEA,gBAAMI,mBAAmB,KAAKnB,IAAL,CAAUA,IAAV,CAAeoB,KAAf,CAAqBC,IAArB,CAA0B,UAACC,CAAD;AAAA,uBAC/C,CAAC,OAAKN,WAAL,CAAiBC,YAAjB,GAAgCK,EAAEC,KAAF,IAAWT,IAAII,QAA/C,GAA0DI,EAAEE,aAAF,IAAmBT,OAA9E,KACCO,EAAEG,UAAF,IAAgBX,IAAIjB,aAAJ,CAAkB6B,IAFY;AAAA,aAA1B,CAAzB;;AAIA,gBAAIP,gBAAJ,EAAsB;;AAEtB,iBAAKnB,IAAL,CAAU2B,OAAV,CAAkBb,IAAIjB,aAAJ,CAAkB6B,IAApC,EAA0CX,OAA1C;AACH;AA3CL;AAAA;AAAA,2BA6COb,IA7CP,EA6Ca0B,QA7Cb,EA6CuB;AACf,8HAAgB,KAAKC,uBAAL,CAA6B3B,IAA7B,CAAhB,EAAoD0B,QAApD;AACH;AA/CL;AAAA;AAAA,gDAiD4B1B,IAjD5B,EAiDkC;AAC1B,gBAAIK,YAAY,EAAhB;AACA,gBAAI,KAAKV,aAAL,CAAmBU,SAAvB,EACIA,YAAY,KAAKV,aAAL,CAAmBU,SAAnB,GAA+B,IAA3C;;AAEJ,mBAAOA,YAAYL,IAAnB;AACH;AAvDL;AAAA;AAAA,4BAyDe;AACP,mBAAO,aAAP;AACH;AA3DL;AAAA;AAAA,4BA4De;AACP,mBAAO,aAAP;AACH;AA9DL;;AAAA;AAAA,EAA0CV,YAAYF,aAAaG,SAAb,CAAZ,CAA1C","file":"subscriber.js","sourcesContent":["const Configurable = require('./configurable');\nconst Monitorable = require('./monitorable');\nconst Component = require('./component');\nconst axon = require('@dashersw/axon');\n\nmodule.exports = class Subscriber extends Monitorable(Configurable(Component)) {\n    constructor(advertisement, discoveryOptions) {\n        super(advertisement, discoveryOptions);\n\n        this.startDiscovery();\n\n        this.sock = new axon.types[this.type]();\n        this.sock.sock.set('retry timeout', 0);\n\n        this.advertisement.subscribesTo = this.advertisement.subscribesTo || ['*'];\n\n        this.advertisement.subscribesTo.forEach((topic) => {\n            let namespace = '';\n            if (this.advertisement.namespace)\n                namespace = this.advertisement.namespace + '::';\n\n            topic = 'message::' + namespace + topic;\n\n            ((topic) => {\n                this.sock.on(topic, (...args) => {\n                    if (args.length == 1)\n                        args.unshift(topic.substr(9));\n                    else\n                        args[0] = namespace + args[0];\n\n                    this.emit(...args);\n                });\n            })(topic);\n        });\n    }\n\n    onAdded(obj) {\n        super.onAdded(obj);\n\n        const address = this.constructor.useHostNames ? obj.hostName : obj.address;\n\n        const alreadyConnected = this.sock.sock.socks.some((s) =>\n            (this.constructor.useHostNames ? s._host == obj.hostName : s.remoteAddress == address) &&\n             s.remotePort == obj.advertisement.port);\n\n        if (alreadyConnected) return;\n\n        this.sock.connect(obj.advertisement.port, address);\n    }\n\n    on(type, listener) {\n        return super.on(this.formatTypeWithNamespace(type), listener);\n    }\n\n    formatTypeWithNamespace(type) {\n        let namespace = '';\n        if (this.advertisement.namespace)\n            namespace = this.advertisement.namespace + '::';\n\n        return namespace + type;\n    }\n\n    get type() {\n        return 'sub-emitter';\n    }\n    get oppo() {\n        return 'pub-emitter';\n    }\n};\n"]}
\ No newline at end of file
+{"version":3,"sources":["../../src/components/subscriber.js"],"names":["Configurable","require","Monitorable","Component","axon","module","exports","advertisement","discoveryOptions","startDiscovery","sock","types","type","set","subscribesTo","forEach","topic","namespace","on","args","length","unshift","substr","emit","obj","address","constructor","useHostNames","hostName","alreadyConnected","socks","some","s","_host","remoteAddress","remotePort","port","connect","listener","formatTypeWithNamespace"],"mappings":";;;;;;;;;;;;AAAA,IAAMA,eAAeC,QAAQ,gBAAR,CAArB;AACA,IAAMC,cAAcD,QAAQ,eAAR,CAApB;AACA,IAAME,YAAYF,QAAQ,aAAR,CAAlB;AACA,IAAMG,OAAOH,QAAQ,gBAAR,CAAb;;AAEAI,OAAOC,OAAP;AAAA;;AACI,wBAAYC,aAAZ,EAA2BC,gBAA3B,EAA6C;AAAA;;AAAA,4HACnCD,aADmC,EACpBC,gBADoB;;AAGzC,cAAKC,cAAL;;AAEA,cAAKC,IAAL,GAAY,IAAIN,KAAKO,KAAL,CAAW,MAAKC,IAAhB,CAAJ,EAAZ;AACA,cAAKF,IAAL,CAAUA,IAAV,CAAeG,GAAf,CAAmB,eAAnB,EAAoC,CAApC;;AAEA,cAAKN,aAAL,CAAmBO,YAAnB,GAAkC,MAAKP,aAAL,CAAmBO,YAAnB,IAAmC,CAAC,GAAD,CAArE;;AAEA,cAAKP,aAAL,CAAmBO,YAAnB,CAAgCC,OAAhC,CAAwC,UAACC,KAAD,EAAW;AAC/C,gBAAIC,YAAY,EAAhB;AACA,gBAAI,MAAKV,aAAL,CAAmBU,SAAvB,EAAkC;AAC9BA,4BAAY,MAAKV,aAAL,CAAmBU,SAAnB,GAA+B,IAA3C;AACH;;AAEDD,oBAAQ,cAAcC,SAAd,GAA0BD,KAAlC;;AAEA,aAAC,UAACA,KAAD,EAAW;AACR,sBAAKN,IAAL,CAAUQ,EAAV,CAAaF,KAAb,EAAoB,YAAa;AAAA,sDAATG,IAAS;AAATA,4BAAS;AAAA;;AAC7B,wBAAIA,KAAKC,MAAL,IAAe,CAAnB,EAAsB;AAClBD,6BAAKE,OAAL,CAAaL,MAAMM,MAAN,CAAa,CAAb,CAAb;AACH,qBAFD,MAEO;AACHH,6BAAK,CAAL,IAAUF,YAAYE,KAAK,CAAL,CAAtB;AACH;AACD,0BAAKI,IAAL,cAAaJ,IAAb;AACH,iBAPD;AAQH,aATD,EASGH,KATH;AAUH,SAlBD;AAVyC;AA6B5C;;AA9BL;AAAA;AAAA,gCAgCYQ,GAhCZ,EAgCiB;AAAA;;AACT,4HAAcA,GAAd;;AAEA,gBAAMC,UAAU,KAAKC,WAAL,CAAiBC,YAAjB,GAAgCH,IAAII,QAApC,GAA+CJ,IAAIC,OAAnE;;AAEA,gBAAMI,mBAAmB,KAAKnB,IAAL,CAAUA,IAAV,CAAeoB,KAAf,CAAqBC,IAArB,CAA0B,UAACC,CAAD;AAAA,uBAC/C,CAAC,OAAKN,WAAL,CAAiBC,YAAjB,GAAgCK,EAAEC,KAAF,IAAWT,IAAII,QAA/C,GAA0DI,EAAEE,aAAF,IAAmBT,OAA9E,KACAO,EAAEG,UAAF,IAAgBX,IAAIjB,aAAJ,CAAkB6B,IAFa;AAAA,aAA1B,CAAzB;;AAIA,gBAAIP,gBAAJ,EAAsB;;AAEtB,iBAAKnB,IAAL,CAAU2B,OAAV,CAAkBb,IAAIjB,aAAJ,CAAkB6B,IAApC,EAA0CX,OAA1C;AACH;AA5CL;AAAA;AAAA,2BA8COb,IA9CP,EA8Ca0B,QA9Cb,EA8CuB;AACf,8HAAgB,KAAKC,uBAAL,CAA6B3B,IAA7B,CAAhB,EAAoD0B,QAApD;AACH;AAhDL;AAAA;AAAA,gDAkD4B1B,IAlD5B,EAkDkC;AAC1B,gBAAIK,YAAY,EAAhB;AACA,gBAAI,KAAKV,aAAL,CAAmBU,SAAvB,EAAkC;AAC9BA,4BAAY,KAAKV,aAAL,CAAmBU,SAAnB,GAA+B,IAA3C;AACH;;AAED,mBAAOA,YAAYL,IAAnB;AACH;AAzDL;AAAA;AAAA,4BA2De;AACP,mBAAO,aAAP;AACH;AA7DL;AAAA;AAAA,4BA+De;AACP,mBAAO,aAAP;AACH;AAjEL;;AAAA;AAAA,EAA0CV,YAAYF,aAAaG,SAAb,CAAZ,CAA1C","file":"subscriber.js","sourcesContent":["const Configurable = require('./configurable');\nconst Monitorable = require('./monitorable');\nconst Component = require('./component');\nconst axon = require('@dashersw/axon');\n\nmodule.exports = class Subscriber extends Monitorable(Configurable(Component)) {\n    constructor(advertisement, discoveryOptions) {\n        super(advertisement, discoveryOptions);\n\n        this.startDiscovery();\n\n        this.sock = new axon.types[this.type]();\n        this.sock.sock.set('retry timeout', 0);\n\n        this.advertisement.subscribesTo = this.advertisement.subscribesTo || ['*'];\n\n        this.advertisement.subscribesTo.forEach((topic) => {\n            let namespace = '';\n            if (this.advertisement.namespace) {\n                namespace = this.advertisement.namespace + '::';\n            }\n\n            topic = 'message::' + namespace + topic;\n\n            ((topic) => {\n                this.sock.on(topic, (...args) => {\n                    if (args.length == 1) {\n                        args.unshift(topic.substr(9));\n                    } else {\n                        args[0] = namespace + args[0];\n                    }\n                    this.emit(...args);\n                });\n            })(topic);\n        });\n    }\n\n    onAdded(obj) {\n        super.onAdded(obj);\n\n        const address = this.constructor.useHostNames ? obj.hostName : obj.address;\n\n        const alreadyConnected = this.sock.sock.socks.some((s) =>\n            (this.constructor.useHostNames ? s._host == obj.hostName : s.remoteAddress == address) &&\n            s.remotePort == obj.advertisement.port);\n\n        if (alreadyConnected) return;\n\n        this.sock.connect(obj.advertisement.port, address);\n    }\n\n    on(type, listener) {\n        return super.on(this.formatTypeWithNamespace(type), listener);\n    }\n\n    formatTypeWithNamespace(type) {\n        let namespace = '';\n        if (this.advertisement.namespace) {\n            namespace = this.advertisement.namespace + '::';\n        }\n\n        return namespace + type;\n    }\n\n    get type() {\n        return 'sub-emitter';\n    }\n\n    get oppo() {\n        return 'pub-emitter';\n    }\n};\n"]}
\ No newline at end of file
diff --git a/examples/publisher.js b/examples/publisher.js
index 591f988..2a72f12 100644
--- a/examples/publisher.js
+++ b/examples/publisher.js
@@ -1,21 +1,26 @@
-var Publisher = require('../').Publisher;
+let Publisher = require('../').Publisher;
 
 // Instantiate a new Publisher component.
-var randomPublisher = new Publisher({
+let randomPublisher = new Publisher({
     name: 'randomPub',
     // namespace: 'rnd',
-    broadcasts: ['randomUpdate']
+    broadcasts: ['update1', 'update2'],
 });
 
 function publishUpdate() {
-    var val = {
-        val: ~~(Math.random() * 1000)
+    let val = {
+        val: ~~(Math.random() * 1000),
     };
 
     console.log('emitting', val);
 
     // publish an event with arbitrary data at any time
-    randomPublisher.publish('randomUpdate', val);
+    randomPublisher.publish('update1', { val: val.val + ' without room' });
+    randomPublisher.publish('update1', { val: val.val + ' on room1 and room3', __rooms: ['room1', 'room3'] });
+    randomPublisher.publish('update1', { val: val.val + ' on room1 only', __room: 'room1' });
+
+    randomPublisher.publish('update3', { val: 'should not be getting this' });
+    randomPublisher.publish('update1', { val: 'should not be getting this', __rooms: ['room2'] });
 }
 
 publishUpdate();
diff --git a/examples/rndpublisher.js b/examples/rndpublisher.js
index d9a42ce..802fbac 100644
--- a/examples/rndpublisher.js
+++ b/examples/rndpublisher.js
@@ -1,17 +1,17 @@
-var Publisher = require('../').Publisher;
+let Publisher = require('../').Publisher;
 
 // Instantiate a new Publisher component.
-var randomPublisher = new Publisher({
+let randomPublisher = new Publisher({
     name: 'randomPub',
     namespace: 'rnd',
-    broadcasts: ['randomUpdate']
+    broadcasts: ['randomUpdate'],
 });
 
 // Wait for the publisher to find an open port and listen on it.
 randomPublisher.on('ready', function() {
     setInterval(function() {
-        var val = {
-            val: ~~(Math.random() * 1000)
+        let val = {
+            val: ~~(Math.random() * 1000),
         };
 
         console.log('emitting', val);
diff --git a/examples/rndresponder.js b/examples/rndresponder.js
index e8d4a12..e4543fa 100644
--- a/examples/rndresponder.js
+++ b/examples/rndresponder.js
@@ -1,16 +1,16 @@
-var Responder = require('../').Responder;
+let Responder = require('../').Responder;
 
 // Instantiate a new Responder component.
-var randomResponder = new Responder({
+let randomResponder = new Responder({
     name: 'randomRep',
     namespace: 'rnd',
-    respondsTo: ['randomRequest'] // types of requests this responder
+    respondsTo: ['randomRequest'], // types of requests this responder
     							  // can respond to.
 });
 
 // request handlers are like any event handler.
 randomResponder.on('randomRequest', function(req, cb) {
-    var answer = ~~(Math.random() * 10);
+    let answer = ~~(Math.random() * 10);
     console.log('request', req.val, 'answering with', answer);
     cb(answer);
 });
diff --git a/examples/sockend/index.html b/examples/sockend/index.html
index 5bedfd1..17cd266 100644
--- a/examples/sockend/index.html
+++ b/examples/sockend/index.html
@@ -3,6 +3,13 @@
 var socket = io.connect();
 var socketNamespaced = io.connect('/rnd');
 
+socket.on('update1',function(data){
+    console.log(data);
+});
+socket.on('update2',function(data){
+    console.log(data);
+});
+
 setInterval(function() {
     var req = {
         val: Math.floor(Math.random() * 10)
diff --git a/examples/sockend/sockend.js b/examples/sockend/sockend.js
index a2fe9bc..a020bbb 100644
--- a/examples/sockend/sockend.js
+++ b/examples/sockend/sockend.js
@@ -1,8 +1,17 @@
-var cote = require('cote'),
-    app = require('http').createServer(handler),
+let cote;
+try {
+    cote = require('cote');
+} catch (e) {
+    cote = require('../../');
+}
+let app = require('http').createServer(handler),
     io = require('socket.io').listen(app),
     fs = require('fs');
 
+io.on('connection', (socket) => {
+   socket.join('room1');
+});
+
 app.listen(process.argv[2] || 5555);
 
 function handler(req, res) {
@@ -17,4 +26,4 @@ function handler(req, res) {
     });
 };
 
-var sockend = new cote.Sockend(io, { name: 'sockend' });
+let sockend = new cote.Sockend(io, { name: 'sockend' });
diff --git a/src/components/publisher.js b/src/components/publisher.js
index 9aec049..7f60b8a 100644
--- a/src/components/publisher.js
+++ b/src/components/publisher.js
@@ -33,17 +33,18 @@ module.exports = class Publisher extends Configurable(Component) {
     publish(topic, data) {
         let namespace = '';
 
-        if (this.advertisement.namespace)
+        if (this.advertisement.namespace) {
             namespace = this.advertisement.namespace + '::';
+        }
 
         topic = 'message::' + namespace + topic;
-
         this.sock.emit(topic, data);
     };
 
     get type() {
         return 'pub-emitter';
     }
+
     get oppo() {
         return 'sub-emitter';
     }
diff --git a/src/components/sockend.js b/src/components/sockend.js
index ce62890..cdbe728 100644
--- a/src/components/sockend.js
+++ b/src/components/sockend.js
@@ -91,24 +91,37 @@ module.exports = class Sockend extends Configurable(Component) {
                 subscribesTo: obj.advertisement.broadcasts,
             }, discoveryOptions);
 
-            subscriber.onMonitorAdded = () => { };
+            subscriber.onMonitorAdded = () => {
+            };
 
             obj.subscriber = subscriber;
 
-            subscriber.on('**', function(data) {
+            subscriber.on('**', function (data) {
                 if (this.event == 'cote:added' || this.event == 'cote:removed') return;
 
                 let topic = this.event.split('::');
                 let namespace = '';
-
                 if (topic.length > 1) {
                     namespace += '/' + topic[0];
                     topic = topic.slice(1);
                 }
-
                 topic = topic.join('');
 
-                io.of(namespace).emit(topic, data);
+                let emitter = io.of(namespace);
+                if (data.__room) {
+                    data.__rooms = new Set(data.__rooms || []);
+                    data.__rooms.add(data.__room);
+                    delete data.__room;
+                }
+                if (data.__rooms) {
+                    const rooms = data.__rooms;
+                    delete data.__rooms;
+                    rooms.forEach((room) => {
+                        emitter.to(room).emit(topic, data);
+                    });
+                } else {
+                    emitter.emit(topic, data);
+                }
             });
         });
     };
diff --git a/src/components/subscriber.js b/src/components/subscriber.js
index cb1b4e4..6cff4cc 100644
--- a/src/components/subscriber.js
+++ b/src/components/subscriber.js
@@ -16,18 +16,19 @@ module.exports = class Subscriber extends Monitorable(Configurable(Component)) {
 
         this.advertisement.subscribesTo.forEach((topic) => {
             let namespace = '';
-            if (this.advertisement.namespace)
+            if (this.advertisement.namespace) {
                 namespace = this.advertisement.namespace + '::';
+            }
 
             topic = 'message::' + namespace + topic;
 
             ((topic) => {
                 this.sock.on(topic, (...args) => {
-                    if (args.length == 1)
+                    if (args.length == 1) {
                         args.unshift(topic.substr(9));
-                    else
+                    } else {
                         args[0] = namespace + args[0];
-
+                    }
                     this.emit(...args);
                 });
             })(topic);
@@ -41,7 +42,7 @@ module.exports = class Subscriber extends Monitorable(Configurable(Component)) {
 
         const alreadyConnected = this.sock.sock.socks.some((s) =>
             (this.constructor.useHostNames ? s._host == obj.hostName : s.remoteAddress == address) &&
-             s.remotePort == obj.advertisement.port);
+            s.remotePort == obj.advertisement.port);
 
         if (alreadyConnected) return;
 
@@ -54,8 +55,9 @@ module.exports = class Subscriber extends Monitorable(Configurable(Component)) {
 
     formatTypeWithNamespace(type) {
         let namespace = '';
-        if (this.advertisement.namespace)
+        if (this.advertisement.namespace) {
             namespace = this.advertisement.namespace + '::';
+        }
 
         return namespace + type;
     }
@@ -63,6 +65,7 @@ module.exports = class Subscriber extends Monitorable(Configurable(Component)) {
     get type() {
         return 'sub-emitter';
     }
+
     get oppo() {
         return 'pub-emitter';
     }
diff --git a/test/sockend.js b/test/sockend.js
index e67360c..ff323ef 100644
--- a/test/sockend.js
+++ b/test/sockend.js
@@ -67,6 +67,58 @@ test.cb('Sockend simple pub&sub', (t) => {
     });
 });
 
+test.cb('Sockend pub&sub with __rooms', (t) => {
+    t.plan(1);
+    const key = r.generate();
+
+    const publisher = new Publisher({ name: `${t.title}: room publisher`, key, broadcasts: ['published message'] });
+
+    portfinder.getPort({ port: 20001 }, (err, port) => {
+        const server = io(port);
+        new Sockend(server, { name: 'pub&sub sockend', key });
+
+        const client = ioClient.connect(`http://0.0.0.0:${port}`);
+
+        client.on('published message', (msg) => {
+            t.deepEqual(msg, { content: 'simple content' });
+            t.end();
+        });
+
+        server.on('connection', (sock) => {
+            sock.join('room1');
+            publisher.sock.sock.on('connect', (sdf) => {
+                publisher.publish('published message', { content: 'simple content', __rooms: ['room1'] });
+            });
+        });
+    });
+});
+
+test.cb('Sockend pub&sub with __room', (t) => {
+    t.plan(1);
+    const key = r.generate();
+
+    const publisher = new Publisher({ name: `${t.title}: room publisher`, key, broadcasts: ['published message'] });
+
+    portfinder.getPort({ port: 20002 }, (err, port) => {
+        const server = io(port);
+        new Sockend(server, { name: 'pub&sub sockend', key });
+
+        const client = ioClient.connect(`http://0.0.0.0:${port}`);
+
+        client.on('published message', (msg) => {
+            t.deepEqual(msg, { content: 'simple content' });
+            t.end();
+        });
+
+        server.on('connection', (sock) => {
+            sock.join('room1');
+            publisher.sock.sock.on('connect', (sdf) => {
+                publisher.publish('published message', { content: 'simple content', __room: 'room1' });
+            });
+        });
+    });
+});
+
 test.cb(`Sockend ns req&res / pub&sub`, (t) => {
     t.plan(2);
 
@@ -76,12 +128,18 @@ test.cb(`Sockend ns req&res / pub&sub`, (t) => {
     portfinder.getPort({ port: 30000 }, (err, port) => {
         const server = io(port);
         new Sockend(server, { name: 'ns sockend', key });
-        const responder = new Responder({ name: `${t.title}: ns responder`, namespace, key,
-            respondsTo: ['ns test'] });
-        const responder2 = new Responder({ name: `${t.title}: ns responder 2`, namespace, key,
-            respondsTo: ['ns test'] });
-        const publisher = new Publisher({ name: `${t.title}: ns publisher`, namespace, key,
-            broadcasts: ['published message'] });
+        const responder = new Responder({
+            name: `${t.title}: ns responder`, namespace, key,
+            respondsTo: ['ns test'],
+        });
+        const responder2 = new Responder({
+            name: `${t.title}: ns responder 2`, namespace, key,
+            respondsTo: ['ns test'],
+        });
+        const publisher = new Publisher({
+            name: `${t.title}: ns publisher`, namespace, key,
+            broadcasts: ['published message'],
+        });
 
         responder.on('ns test', (req, cb) => cb(req.args));
         responder2.on('ns test', (req, cb) => cb(req.args));
@@ -119,8 +177,10 @@ test.cb(`Sockend ns late bound req&res`, (t) => {
     portfinder.getPort({ port: 50000 }, (err, port) => {
         const server = io(port);
         server.of(`/${namespace}`, (socket) => {
-            const responder = new Responder({ name: `${t.title}: ns responder`, namespace, key,
-                respondsTo: ['ns test'] });
+            const responder = new Responder({
+                name: `${t.title}: ns responder`, namespace, key,
+                respondsTo: ['ns test'],
+            });
             responder.on('ns test', (req, cb) => cb(req.args));
             client.emit('ns test', { args: [7, 8, 9] }, (res) => {
                 t.deepEqual(res, [7, 8, 9]);