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

+per #17837 Detect (and repair) corrupt event streams

Browse source 
refactoring of plugin config
This commit is contained in:
Patrik Nordwall 2015-08-12 13:32:30 +02:00
parent 5c6304e2eb
commit c5851600f0
10 changed files with 573 additions and 101 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-persistence/src/main/scala/akka/persistence/snapshot/SnapshotStore.scala
View file

@ -23,15 +23,10 @@ trait SnapshotStore extends Actor with ActorLogging {
private val publish = extension.settings.internal.publishPluginCommands
private val breaker = {
val cfg = context.system.settings.config
val cbConfig =
if (cfg.hasPath(self.path.name + ".circuit-breaker"))
cfg.getConfig(self.path.name + ".circuit-breaker")
.withFallback(cfg.getConfig("akka.persistence.default-circuit-breaker"))
else cfg.getConfig("akka.persistence.default-circuit-breaker")
val maxFailures = cbConfig.getInt("max-failures")
val callTimeout = cbConfig.getDuration("call-timeout", MILLISECONDS).millis
val resetTimeout = cbConfig.getDuration("reset-timeout", MILLISECONDS).millis
val cfg = extension.configFor(self)
val maxFailures = cfg.getInt("circuit-breaker.max-failures")
val callTimeout = cfg.getDuration("circuit-breaker.call-timeout", MILLISECONDS).millis
val resetTimeout = cfg.getDuration("circuit-breaker.reset-timeout", MILLISECONDS).millis
CircuitBreaker(context.system.scheduler, maxFailures, callTimeout, resetTimeout)
}