mongodb 更改流无法解析订阅
mongodb change stream cannot resolve subscribe
我想在 mongo 数据库上设置更改流,
但是有一个 "Cannot resolve overloaded method subscribe",我找不到问题的根源:
import org.mongodb.scala.{Document, MongoClient, MongoCollection, MongoDatabase}
object App {
def main(args: Array[String]): Unit = {
val mongoClient: MongoClient = MongoClient("mongodb://localhost")
val database: MongoDatabase = mongoClient.getDatabase("db")
val collection: MongoCollection[Document] = database.getCollection("col")
collection.watch().subscribe(
(doc: Document) => println(doc.toJson),
(t: Throwable) => println(""),
() => println()
)
}
}
libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.7.0"
替换:
(doc: Document) => println(doc.toJson),
与:
(csd: ChangeStreamDocument[Document]) => println(csd.getFullDocument()),
我想在 mongo 数据库上设置更改流, 但是有一个 "Cannot resolve overloaded method subscribe",我找不到问题的根源:
import org.mongodb.scala.{Document, MongoClient, MongoCollection, MongoDatabase}
object App {
def main(args: Array[String]): Unit = {
val mongoClient: MongoClient = MongoClient("mongodb://localhost")
val database: MongoDatabase = mongoClient.getDatabase("db")
val collection: MongoCollection[Document] = database.getCollection("col")
collection.watch().subscribe(
(doc: Document) => println(doc.toJson),
(t: Throwable) => println(""),
() => println()
)
}
}
libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.7.0"
替换:
(doc: Document) => println(doc.toJson),
与:
(csd: ChangeStreamDocument[Document]) => println(csd.getFullDocument()),