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

+per #17799 Fix refactoring bug in deleteMessages

Browse source 
* add missing test
* use DeleteMessagesFailure and add onDeleteMessagesFailure (logging)
This commit is contained in:
Patrik Nordwall 2015-06-26 10:36:27 +02:00
parent dd13de5559
commit 77df1372ad
8 changed files with 61 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
View file

@ -20,6 +20,7 @@ object PersistentActorSpec {
final case class Cmd(data: Any)
final case class Evt(data: Any)
final case class LatchCmd(latch: TestLatch, data: Any) extends NoSerializationVerificationNeeded
final case class Delete(toSequenceNr: Long)
abstract class ExamplePersistentActor(name: String) extends NamedPersistentActor(name) with PersistentActor {
var events: List[Any] = Nil
@ -29,8 +30,9 @@ object PersistentActorSpec {
}
val commonBehavior: Receive = {
case "boom" ⇒ throw new TestException("boom")
case GetState ⇒ sender() ! events.reverse
case "boom" ⇒ throw new TestException("boom")
case Delete(toSequenceNr) ⇒ deleteMessages(toSequenceNr)
case GetState ⇒ sender() ! events.reverse
}
def receiveRecover = updateState
@ -892,6 +894,17 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
expectNoMsg(100.millis)
}
"be able to delete events" in {
val persistentActor = namedPersistentActor[Behavior1PersistentActor]
persistentActor ! Cmd("b")
persistentActor ! GetState
expectMsg(List("a-1", "a-2", "b-1", "b-2"))
persistentActor ! Delete(2L) // delete "a-1" and "a-2"
persistentActor ! "boom" // restart, recover
persistentActor ! GetState
expectMsg(List("b-1", "b-2"))
}
}
}