diff --git a/test/pubsub.js b/test/pubsub.js index 5fb082a210..873e252e2a 100644 --- a/test/pubsub.js +++ b/test/pubsub.js @@ -12,24 +12,44 @@ describe('pubsub', function () { pubsub.reset(); pubsub.on('testEvent', function (message) { assert.equal(message.foo, 1); - nconf.set('isCluster', 'true'); pubsub.removeAllListeners('testEvent'); - pubsub.reset(); done(); }); pubsub.publish('testEvent', { foo: 1 }); }); + it('should use same event emitter', function (done) { + pubsub.on('dummyEvent', function (message) { + assert.equal(message.foo, 2); + nconf.set('isCluster', 'true'); + pubsub.removeAllListeners('dummyEvent'); + pubsub.reset(); + done(); + }); + pubsub.publish('dummyEvent', { foo: 2 }); + }); + it('should use singleHostCluster', function (done) { var oldValue = nconf.get('singleHostCluster'); nconf.set('singleHostCluster', true); pubsub.on('testEvent', function (message) { - assert.equal(message.foo, 2); + assert.equal(message.foo, 3); nconf.set('singleHostCluster', oldValue); pubsub.removeAllListeners('testEvent'); + done(); + }); + pubsub.publish('testEvent', { foo: 3 }); + }); + + it('should use same event emitter', function (done) { + var oldValue = nconf.get('singleHostCluster'); + pubsub.on('dummyEvent', function (message) { + assert.equal(message.foo, 4); + nconf.set('singleHostCluster', oldValue); + pubsub.removeAllListeners('dummyEvent'); pubsub.reset(); done(); }); - pubsub.publish('testEvent', { foo: 2 }); + pubsub.publish('dummyEvent', { foo: 4 }); }); });