raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fix LeveldbEndToEndEventAdapterSpec, it's not logging because journal not started

Browse source
This commit is contained in:
Patrik Nordwall 2020-02-12 16:50:18 +01:00
parent 01b95c50ec
commit 21bbae8c46
1 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-persistence/src/test/scala/akka/persistence/EndToEndEventAdapterSpec.scala
View file

@ -8,7 +8,7 @@ import java.io.File
import akka.actor._ import akka.actor._
import akka.persistence.journal.{ EventAdapter, EventSeq } import akka.persistence.journal.{ EventAdapter, EventSeq }
import akka.testkit.{ EventFilter, TestProbe } import akka.testkit.TestProbe
import akka.util.unused import akka.util.unused
import com.typesafe.config.{ Config, ConfigFactory } import com.typesafe.config.{ Config, ConfigFactory }
import org.apache.commons.io.FileUtils import org.apache.commons.io.FileUtils
@ -233,11 +233,9 @@ abstract class EndToEndEventAdapterSpec(journalName: String, journalConfig: Conf
s"""$journalPath.event-adapter-bindings."${classOf[EndToEndEventAdapterSpec].getCanonicalName}$$A"""") s"""$journalPath.event-adapter-bindings."${classOf[EndToEndEventAdapterSpec].getCanonicalName}$$A"""")
withActorSystem("MissingAdapterSystem", journalConfig.withFallback(missingAdapterConfig)) { implicit system2 => withActorSystem("MissingAdapterSystem", journalConfig.withFallback(missingAdapterConfig)) { implicit system2 =>
EventFilter[ActorInitializationException](occurrences = 1, pattern = ".*undefined event-adapter.*").intercept { intercept[IllegalArgumentException] {
intercept[IllegalArgumentException] { Persistence(system2).adaptersFor(s"akka.persistence.journal.$journalName").get(classOf[String])
Persistence(system2).adaptersFor(s"akka.persistence.journal.$journalName").get(classOf[String]) }.getMessage should include("was bound to undefined event-adapter: a (bindings: [a, b], known adapters: b)")
}.getMessage should include("was bound to undefined event-adapter: a (bindings: [a, b], known adapters: b)")
}
} }
} }
} }