Comparing version 0.1.2 to 0.1.3
@@ -29,3 +29,3 @@ /** | ||
var db; | ||
if (options instanceof AsyncDb) { | ||
if (options.db) { | ||
db = options; | ||
@@ -35,5 +35,5 @@ } else { | ||
var server = connect(options.host, options.port, {poolSize: options.poolSize}); | ||
db = server.db(options.db); | ||
db = server.db(options.name); | ||
} | ||
return new Queue(db); | ||
}; |
@@ -180,3 +180,3 @@ /** | ||
name: task.name, | ||
started: new Date, | ||
started: new Date(), | ||
state: common.STATE_INPROGRESS | ||
@@ -186,3 +186,3 @@ }; | ||
task.fn.call(message, message.message, function (taskErr, result) { | ||
var ts = new Date; | ||
var ts = new Date(); | ||
log.finished = ts; | ||
@@ -196,7 +196,9 @@ log.date = common.getDateString(ts); | ||
self.errColl.insert(log, {safe: true}).fail(self._onFault(self)); | ||
self.emit('error', log.error, log); | ||
if (self.listeners('error').length > 0) { | ||
self.emit('error', log.error, log); | ||
} | ||
} else { | ||
log.state = common.STATE_FINISHED; | ||
// record result if any | ||
if (result != undefined) { | ||
if (result !== undefined) { | ||
hasResult = true; | ||
@@ -221,3 +223,5 @@ results[task.name] = result; | ||
self.errColl.insert(log, {safe: true}).fail(self._onFault(self)); | ||
self.emit('error', log.error, log); | ||
if (self.listeners('error').length > 0) { | ||
self.emit('error', log.error, log); | ||
} | ||
} | ||
@@ -224,0 +228,0 @@ }); |
{ | ||
"name" : "nomoque", | ||
"version" : "0.1.2", | ||
"description" : "A task queue powered by nodejs and mongodb", | ||
"keywords" : ["task", "queue", "mongodb"], | ||
"version" : "0.1.3", | ||
"description" : "Database Centric Distributed Task Queue", | ||
"keywords" : ["task", "queue", "mongodb", "database", "distributed"], | ||
"homepage" : "https://github.com/lsm/nomoque", | ||
@@ -7,0 +7,0 @@ "author" : "Senmiao Liu <senmiao.liu@gmail.com>", |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
No README
QualityPackage does not have a README. This may indicate a failed publish or a low quality package.
Found 1 instance in 1 package
12695
6
382
1
43
0