Merge pull request #47 from scullxbones/mongo-driver-51

update mongodb-driver to 5.1.1

build.sbt

@@ -7,15 +7,15 @@ val scala3V = "3.4.1"
 val scalaV = scala213V
 val pekkoV = "1.0.2"
 
-val MongoJavaDriverVersion = "4.11.2"
+val MongoJavaDriverVersion = "5.1.1"
 val Log4jVersion = "2.23.1"
 val NettyVersion = "4.1.111.Final"
 
 val commonDeps = Seq(
   ("org.apache.pekko"  %% "pekko-persistence" % pekkoV)
     .exclude("org.iq80.leveldb", "leveldb")
     .exclude("org.fusesource.leveldbjni", "leveldbjni-all"),
-  ("nl.grons" %% "metrics4-scala" % "4.2.9"),
+  "nl.grons"                 %% "metrics4-scala"            % "4.2.9",
   "org.apache.pekko"         %% "pekko-persistence-query"   % pekkoV     % "compile",
   "org.apache.pekko"         %% "pekko-persistence"         % pekkoV     % "compile",
   "org.apache.pekko"         %% "pekko-actor"               % pekkoV     % "compile",

scala/src/main/scala/pekko/contrib/persistence/mongodb/driver/ScalaDriverPersistenceExtension.scala

@@ -42,7 +42,7 @@ class ScalaMongoDriver(system: ActorSystem, config: Config) extends MongoPersist
   override def ensureCollection(name: String): Future[C] =
     ensureCollection(name, db.createCollection)
 
-  private[this] def ensureCollection(name: String, collectionCreator: String => SingleObservable[Void]): Future[C] =
+  private[this] def ensureCollection(name: String, collectionCreator: String => SingleObservable[Unit]): Future[C] =
     for {
       _ <- collectionCreator(name).toFuture().recover { case MongoErrors.NamespaceExists() => () }
       mongoCollection <- collection(name)

scala/src/main/scala/pekko/contrib/persistence/mongodb/driver/ScalaDriverSettings.scala

@@ -73,7 +73,7 @@ class ScalaDriverSettings(config: Config) extends OfficialDriverSettings(config)
     )
 
     if (SslEnabled) {
-      bldr.streamFactoryFactory(NettyStreamFactoryFactory())
+      bldr.transportSettings(TransportSettings.nettyBuilder().build())
     } else bldr
 
   }