使用mongodb和rabbitmq处理任务

-1

我订阅了该作业，并且侦听到了新消息，我得到了一个与MongoDB的ObjectId类似的ID。当我使用本机MongoDB驱动程序时，一切正常，但是当我尝试使用Mongoose时出现此错误：findOne方法返回队列中的先前值。使用mongodb和rabbitmq处理任务

我的尝试：

q.subscribe((message, headers, deliveryInfo, ack) => { 
    const workerId = message.workerId; // everytime changed, it`s ok! 
    MongoClient.connect(url, (err, db) => { 
     const collection = db.collection('workers'); 
     collection.findOne({_id: workerId}, (err, item) => { 
     logger.info('native ', item); // return actual data by id 
     }); 
    }); 

    Workers.findOne(workerId, (err, item) => { 
     logger.info('mongoose ', item); // return previos value! why??? workerId changed it other values, because it another job 
    }); 
});

所以，猫鼬返回旧的对象，而我没有跑

ack.acknowledge(true);

来源

2016-03-02 VladL

呼叫Workers.findById(workerId, ...，它会回报你想要什么

来源

2016-03-02 18:56:08

使用mongodb和rabbitmq处理任务

回答

相关问题