keuss - npm Package Compare versions

Comparing version 1.0.3 to 1.0.4

bench/multi-q.js

bench/redis-oq-consumer-producer.js

		@@ -10,3 +10,3 @@ var async = require ('async');
		new (winston.transports.Console)({
		level: 'verbose',
		level: 'info',
		timestamp: function() {return new Date ();},
		@@ -25,4 +25,4 @@ formatter: function (options) {
		q.pop ('c1', {}, function (err, res) {
		logger.verbose ('consumer: got err %j', err, {});
		logger.verbose ('consumer: got res %j', res, {});
		// logger.verbose ('consumer: got err %j', err, {});
		// logger.verbose ('consumer: got res %j', res, {});

		@@ -37,8 +37,8 @@ // setTimeout (function () {
		q.push ({a:1, b:'666'}, function (err, res) {
		logger.verbose ('producer: got err %j', err, {});
		logger.verbose ('producer: got res %j', res, {});
		// logger.verbose ('producer: got err %j', err, {});
		// logger.verbose ('producer: got res %j', res, {});

		setTimeout (function () {
		// setTimeout (function () {
		run_producer (q);
		}, (random.from0to (10) + 1) * 1000);
		// }, (random.from0to (10) + 1) * 1000);
		});
		@@ -45,0 +45,0 @@ }

package.json

		{
		"name": "keuss",
		"version": "1.0.3",
		"version": "1.0.4",
		"keywords": ["queue", "job"],
		@@ -5,0 +5,0 @@ "homepage":"https://github.com/pepmartinez/keuss",

signal/redis-pubsub.js

		@@ -5,4 +5,4 @@ 'use strict';

		var RedisConn = require ('../utils/RedisConn');
		var Signal = require ('../Signal');
		var RedisConn = require ('../utils/RedisConn');
		var Signal = require ('../Signal');

		@@ -20,3 +20,3 @@ class RPSSignal extends Signal {
		var mature = parseInt (message);
		self._verbose ('got redis pubsub event on ch [%s], message is %s, calling master.emitInsertion(%d)', self._channel, message, mature);
		self._verbose ('got mitt pubsub event on ch [%s], message is %s, calling master.emitInsertion(%d)', self._channel, message, mature);
		self._master.signalInsertion (new Date (mature));
		@@ -29,9 +29,2 @@ });
		this._rediscl_sub.subscribe (this._channel);

		this._rediscl_sub.on ('message', function (channel, message) {
		self._verbose ('got redis pubsub event on ch [%s], message is %s,calling master.emitInsertion(%d)', channel, message, mature);

		// convey to local through mitt
		self._factory._emitter.emit (channel, message);
		});

		@@ -55,2 +48,8 @@ this._verbose ('created redis-pubsub signaller on channel [%s]', this._channel);
		this._rediscl_sub = RedisConn.conn (this._opts);

		var self = this;
		this._rediscl_sub.on ('message', function (channel, message) {
		// convey to local through mitt
		self._emitter.emit (channel, message);
		});
		}
		@@ -57,0 +56,0 @@

New alerts