MongoDB Queuing Test

queue.js

insertQ = function () {
    for (i = 0; i < 1000; i++) {
        db.queue.insert({message:"amessage", count:i, ts:new Date, status:"new"});
        print("Count:" + i);
	sleep(250);
    }
}

dQueue = function() {
 for(i=0;i<1000;i++)  {
    print("Messages in queue:"+db.queue.count({status:'new'}));
 var msg = db.queue.findAndModify({query : {status:"new"}, update :{$set: {status:"inprogress"}}, new:true});
 printjson(msg)
 sleep(25);
 }
}