Fix CollectionNameMapping instantiation (#3)

null-vector · Jan 29, 2020 · 3001eca · 3001eca
1 parent e74df40
commit 3001eca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/build.sbt b/build.sbt
@@ -6,7 +6,7 @@ lazy val rxmongoVersion = "0.18.8"
 
 name := "akka-reactivemongo-plugin"
 organization := "null-vector"
-version := "1.2.10"
+version := "1.2.11"
 scalaVersion := scala213
 crossScalaVersions := supportedScalaVersions
 scalacOptions ++= Seq(

diff --git a/src/main/scala/org/nullvector/ReactiveMongoDriver.scala b/src/main/scala/org/nullvector/ReactiveMongoDriver.scala
@@ -65,9 +65,9 @@ class ReactiveMongoDriver(system: ExtendedActorSystem) extends Extension {
     private val snapshotPrefix = system.settings.config.getString("akka-persistence-reactivemongo.prefix-collection-snapshot")
     private val verifiedNames: mutable.HashSet[String] = mutable.HashSet[String]()
 
-    private val nameMapping: CollectionNameMapping = system.getClass.getClassLoader.loadClass(
+    private val nameMapping: CollectionNameMapping = system.dynamicAccess.getClassFor[CollectionNameMapping](
       system.settings.config.getString("akka-persistence-reactivemongo.collection-name-mapping")
-    ).newInstance().asInstanceOf[CollectionNameMapping]
+    ).get.newInstance()
 
     override def receive: Receive = {
       case GetJournalCollectionNameFor(persistentId, promise) =>