Package org.apache.pekko.persistence.testkit.internal

Class InMemStorageExtension

java.lang.Object

org.apache.pekko.persistence.testkit.internal.InMemStorageExtension

All Implemented Interfaces:

Extension

public final class InMemStorageExtension
extends Object
implements Extension

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
InMemStorageExtension(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static InMemStorageExtension	createExtension(ExtendedActorSystem system)
ProcessingPolicy<JournalOperation>	currentPolicy()
EventStorage	defaultStorage()
static final boolean	equals(Object other)
static InMemStorageExtension	get(ActorSystem system)
static final int	hashCode()
static InMemStorageExtension$	lookup()
void	resetPolicy()
void	setPolicy(ProcessingPolicy<JournalOperation> policy)
EventStorage	storageFor(String key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemStorageExtension

public InMemStorageExtension(ExtendedActorSystem system)

Method Details

get

public static InMemStorageExtension get(ActorSystem system)

createExtension

public static InMemStorageExtension createExtension(ExtendedActorSystem system)

lookup

public static InMemStorageExtension$ lookup()

apply

public static T apply(ActorSystem system)

apply

public static T apply(ClassicActorSystemProvider system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(Object other)

defaultStorage

public EventStorage defaultStorage()

currentPolicy

public ProcessingPolicy<JournalOperation> currentPolicy()

setPolicy

public void setPolicy(ProcessingPolicy<JournalOperation> policy)

resetPolicy

public void resetPolicy()

storageFor

public EventStorage storageFor(String key)