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

Updates deprecations and documentation #26156

Browse source
This commit is contained in:
Nicolas Vollmar 2019-03-07 09:58:31 +01:00
parent f4b6e30810
commit 4bf1ba0bf0
7 changed files with 33 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-docs/src/test/scala/docs/persistence/PersistenceDocSpec.scala
View file

@ -5,10 +5,10 @@
package docs.persistence
import akka.actor._
import akka.pattern.{ Backoff, BackoffSupervisor }
import akka.pattern.{ Backoff, BackoffOpts, BackoffSupervisor }
import akka.persistence._
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{ Source, Sink, Flow }
import akka.stream.scaladsl.{ Flow, Sink, Source }
import scala.concurrent.duration._
import scala.language.postfixOps
@ -96,15 +96,14 @@ object PersistenceDocSpec {
abstract class MyActor extends Actor {
import PersistAsync.MyPersistentActor
//#backoff
val childProps = Props[MyPersistentActor]
val childProps = Props[MyPersistentActor]()
val props = BackoffSupervisor.props(
Backoff.onStop(
BackoffOpts.onStop(
childProps,
childName = "myActor",
minBackoff = 3.seconds,
maxBackoff = 30.seconds,
randomFactor = 0.2,
maxNrOfRetries = -1))
randomFactor = 0.2))
context.actorOf(props, name = "mySupervisor")
//#backoff
}