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

Nested Class Summary

static class	JournalSpec.Confirmation
static class	JournalSpec.Confirmation$

Method Summary

void	beforeEach()
ActorRef	journal()
TestProbe	receiverProbe()
JournalProtocol.ReplayedMessage	replayedMessage(long snr, boolean deleted, scala.collection.immutable.Seq<java.lang.String> confirms)
TestProbe	senderProbe()
ActorSystem	system()
void	writeMessages(int from, int to, java.lang.String pid, ActorRef sender)

Methods inherited from interface akka.persistence.PluginSpec

_extension, _pid, actorInstanceId, afterAll, beforeAll, config, counter, extension, pid, subscribe

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

Method Detail

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)