akka.persistence.journal
Interface JournalSpec
- All Superinterfaces:
- PluginSpec, TestKitBase
- All Known Implementing Classes:
- JavaJournalPerfSpec, JavaJournalSpec
public interface JournalSpec
- extends PluginSpec
This spec aims to verify custom akka-persistence Journal implementations.
Plugin authors are highly encouraged to include it in their plugin's test suites.
In case your journal plugin needs some kind of setup or teardown, override the beforeAll
or afterAll
methods (don't forget to call super
in your overriden methods).
For a Java and JUnit consumable version of the TCK please refer to JavaJournalSpec
.
- See Also:
JournalPerfSpec
,
JavaJournalPerfSpec
Methods inherited from interface akka.testkit.TestKitBase |
awaitAssert, awaitCond, checkMissingAndUnexpected, end, expectMsg_internal, expectMsg, expectMsg, expectMsg, expectMsgAllClassOf, expectMsgAllClassOf, expectMsgAllConformingOf, expectMsgAllConformingOf, expectMsgAllOf_internal, expectMsgAllOf, expectMsgAllOf, expectMsgAnyClassOf_internal, expectMsgAnyClassOf, expectMsgAnyClassOf, expectMsgAnyOf_internal, expectMsgAnyOf, expectMsgAnyOf, expectMsgClass_internal, expectMsgClass, expectMsgClass, expectMsgPF, expectMsgType, expectMsgType, expectNoMsg_internal, expectNoMsg, expectNoMsg, expectTerminated, fishForMessage, format, ignoreMsg, ignoreNoMsg, internalExpectMsgAllClassOf, internalExpectMsgAllConformingOf, lastMessage, lastSender, lastWasNoMsg, msgAvailable, now, queue, receiveN_internal, receiveN, receiveN, receiveOne, receiveWhile, remaining, remainingOr, remainingOrDilated, setAutoPilot, shutdown, testActor, testKitSettings, unwatch, watch, within, within |
system
ActorSystem system()
- Specified by:
system
in interface TestKitBase
senderProbe
TestProbe senderProbe()
receiverProbe
TestProbe receiverProbe()
beforeEach
void beforeEach()
- Specified by:
beforeEach
in interface PluginSpec
journal
ActorRef journal()
replayedMessage
JournalProtocol.ReplayedMessage replayedMessage(long snr,
boolean deleted,
scala.collection.immutable.Seq<java.lang.String> confirms)
writeMessages
void writeMessages(int from,
int to,
java.lang.String pid,
ActorRef sender)