草庐IT

jobsQueueMaybe

全部标签

mongodb - 使用 ReactiveMongo 处理来自上限集合的作业直到被中断

我在MongoDB中有一个jobs_queue集合。这是一个上限集合,我正在使用可尾游标进行轮询:valcur=jobsQueue.find(Json.obj("done"->Json.obj("$ne"->true))).options(QueryOpts().tailable.awaitData).cursor[JsObject]cur.enumerate()|>>>Iteratee.foreach{queuedDoc=>//dosomeprocessingandstoretheresultsbackintheDB}这是从常规ScalaApp调用的,因此根本没有Akka或Play包