test pubsub cache

v1.18.x
Baris Usakli 6 years ago
parent 444fd70ba3
commit 74fdadf8a6

@ -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 });
});
});

Loading…
Cancel
Save