From edc92eb53eef71507f641fd9acef935738313eaf Mon Sep 17 00:00:00 2001 From: Roland Kuhn Date: Sat, 6 Feb 2016 16:26:44 +0100 Subject: [PATCH] add hook before each persistence TCK test case --- .../main/scala/akka/persistence/journal/JournalSpec.scala | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala index 91edb93763..f2dd86797a 100644 --- a/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala +++ b/akka-persistence-tck/src/main/scala/akka/persistence/journal/JournalSpec.scala @@ -46,9 +46,17 @@ abstract class JournalSpec(config: Config) extends PluginSpec(config) with MayVe super.beforeEach() senderProbe = TestProbe() receiverProbe = TestProbe() + preparePersistenceId(pid) writeMessages(1, 5, pid, senderProbe.ref, writerUuid) } + /** + * Overridable hook that is called before populating the journal for the next + * test case. `pid` is the `persistenceId` that will be used in the test. + * This method may be needed to clean pre-existing events from the log. + */ + def preparePersistenceId(pid: String): Unit = () + /** * Implementation may override and return false if it does not * support atomic writes of several events, as emitted by `persistAll`.