mongodb-queue
Advanced tools
Comparing version 0.2.0 to 0.2.1
@@ -79,2 +79,3 @@ /** | ||
if (err) return callback(err) | ||
if (!msg) return callback() | ||
callback(null, { | ||
@@ -81,0 +82,0 @@ id : msg.id, |
{ | ||
"name": "mongodb-queue", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"description": "Message queues which uses MongoDB.", | ||
@@ -9,3 +9,3 @@ "main": "mongodb-queue.js", | ||
"email": "andychilton@gmail.com", | ||
"url": "http://www.chilts.org/" | ||
"url": "http://chilts.org/" | ||
}, | ||
@@ -12,0 +12,0 @@ "homepage": "https://github.com/chilts/mongodb-queue", |
@@ -112,2 +112,7 @@ # mongodb-queue # | ||
### 0.2.1 (2014-03-19) ### | ||
* [FIX] Fix when getting messages off an empty queue | ||
* [NEW] More Tests | ||
### 0.2.0 (2014-03-18) ### | ||
@@ -114,0 +119,0 @@ |
var mongodb = require('mongodb') | ||
var async = require('async') | ||
var test = require('tape') | ||
var Queue = require('../') | ||
var setup = require('./setup.js') | ||
var conStr = 'mongodb://localhost:27017/mongodb-queue' | ||
test('first test', function(t) { | ||
mongodb.MongoClient.connect(conStr, function(err, db) { | ||
if (err) return t.fail(err) | ||
setup(function(db) { | ||
test('first test', function(t) { | ||
var queue = Queue(db, 'test') | ||
t.pass('This is a test.') | ||
t.ok(queue, 'Queue created ok') | ||
t.end() | ||
db.close() | ||
}) | ||
}); | ||
}); | ||
test('single round trip', function(t) { | ||
mongodb.MongoClient.connect(conStr, function(err, db) { | ||
if (err) return t.fail(err) | ||
test('single round trip', function(t) { | ||
var queue = Queue(db, 'test') | ||
@@ -62,2 +59,3 @@ | ||
}) | ||
}); | ||
}) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
11866
8
213
140