Class SimpleEventStorageImpl
- java.lang.Object
-
- akka.persistence.testkit.internal.SimpleEventStorageImpl
-
- All Implemented Interfaces:
EventStorage
,InMemStorage<java.lang.String,PersistentRepr>
,InternalReprSupport<PersistentRepr>
,PolicyOps<JournalOperation>
,TestKitStorage<JournalOperation,PersistentRepr>
public class SimpleEventStorageImpl extends java.lang.Object implements EventStorage
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.persistence.testkit.EventStorage
EventStorage.JournalPolicies$
-
-
Constructor Summary
Constructors Constructor Description SimpleEventStorageImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
protected ProcessingPolicy.DefaultPolicies.PassAll
DefaultPolicy()
PersistentRepr
toInternal(PersistentRepr repr)
PersistentRepr
toRepr(PersistentRepr internal)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.persistence.testkit.EventStorage
add, addAny, addAny, mapAny, reprToSeqNum, tryAdd, tryDelete, tryRead, tryReadByTag, tryReadSeqNumber
-
Methods inherited from interface akka.persistence.testkit.internal.InMemStorage
add, add, clearAll, clearAllPreservingSeqNumbers, delete, deleteToSeqNumber, eventsMap_$eq, expectNextQueue_$eq, findMany, findOneByIndex, firstInExpectNextQueue, getHighestSeqNumber, getLastSeqNumber, read, read, readAll, removeFirstInExpectNextQueue, removeKey, removePreservingSeqNumber, updateOrSetNew
-
Methods inherited from interface akka.persistence.testkit.internal.InternalReprSupport
toRepr
-
Methods inherited from interface akka.persistence.testkit.internal.PolicyOps
currentPolicy, resetPolicy, setPolicy
-
-
-
-
Method Detail
-
DefaultPolicy
protected ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()
- Specified by:
DefaultPolicy
in interfaceEventStorage
- Specified by:
DefaultPolicy
in interfacePolicyOps<JournalOperation>
-
akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq
protected void akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
- Specified by:
akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq
in interfaceEventStorage
-
toInternal
public PersistentRepr toInternal(PersistentRepr repr)
- Specified by:
toInternal
in interfaceInternalReprSupport<PersistentRepr>
-
toRepr
public PersistentRepr toRepr(PersistentRepr internal)
-
-