Class SerializedEventStorageImpl
- java.lang.Object
-
- akka.persistence.testkit.internal.SerializedEventStorageImpl
-
- All Implemented Interfaces:
EventStorage
,InMemStorage<java.lang.String,PersistentRepr>
,InternalReprSupport<PersistentRepr>
,PolicyOps<JournalOperation>
,TestKitStorage<JournalOperation,PersistentRepr>
public class SerializedEventStorageImpl extends java.lang.Object implements EventStorage
INTERNAL API FIXME, once we add serializers for metadata serialize the metadata payload if present
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SerializedEventStorageImpl.Serialized
static class
SerializedEventStorageImpl.Serialized$
-
Nested classes/interfaces inherited from interface akka.persistence.testkit.EventStorage
EventStorage.JournalPolicies$
-
-
Constructor Summary
Constructors Constructor Description SerializedEventStorageImpl(ActorSystem system)
-
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()
SerializedEventStorageImpl.Serialized
toInternal(PersistentRepr pr)
PersistentRepr
toRepr(SerializedEventStorageImpl.Serialized 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
-
-
-
-
Constructor Detail
-
SerializedEventStorageImpl
public SerializedEventStorageImpl(ActorSystem system)
-
-
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 SerializedEventStorageImpl.Serialized toInternal(PersistentRepr pr)
- Specified by:
toInternal
in interfaceInternalReprSupport<PersistentRepr>
- Returns:
- (serializer id, serialized bytes)
-
toRepr
public PersistentRepr toRepr(SerializedEventStorageImpl.Serialized internal)
- Parameters:
internal
- (serializer id, serialized bytes)
-
-