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

=per #15730 fix context.become in PersistentView

Browse source 
(cherry picked from commit 561bd00cf69b0070693db397fe0dbda824792335)
This commit is contained in:
Roland Kuhn 2014-08-23 18:50:25 +02:00 • committed by Patrik Nordwall
parent f6bf141e97
commit ec55ab2d22
3 changed files with 28 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-persistence/src/test/scala/akka/persistence/PersistentViewSpec.scala
View file

@ -100,6 +100,17 @@ object PersistentViewSpec {
}
}
private class BecomingPersistentView(name: String, probe: ActorRef) extends PersistentView {
override def persistenceId = name
override def viewId = name + "-view"
def receive = Actor.emptyBehavior
context.become {
case payload ⇒ probe ! s"replicated-${payload}-${lastSequenceNr}"
}
}
private class PersistentOrNotTestPersistentView(name: String, probe: ActorRef) extends PersistentView {
override val persistenceId: String = name
override val viewId: String = name + "-view"
@ -281,6 +292,11 @@ abstract class PersistentViewSpec(config: Config) extends AkkaSpec(config) with
replayProbe.expectMsgPF() { case ReplayMessages(3L, _, 2L, _, _, _) ⇒ }
replayProbe.expectMsgPF() { case ReplayMessages(5L, _, 2L, _, _, _) ⇒ }
}
"support context.become" in {
view = system.actorOf(Props(classOf[BecomingPersistentView], name, viewProbe.ref))
viewProbe.expectMsg("replicated-a-1")
viewProbe.expectMsg("replicated-b-2")
}
"check if an incoming message is persistent" in {
persistentActor ! "c"