Package org.apache.pekko.persistence.state

Class DurableStateStoreRegistry

java.lang.Object

org.apache.pekko.persistence.PersistencePlugin<DurableStateStore<?>,DurableStateStore<?>,DurableStateStoreProvider>

org.apache.pekko.persistence.state.DurableStateStoreRegistry

All Implemented Interfaces:

Extension

public class DurableStateStoreRegistry
extends org.apache.pekko.persistence.PersistencePlugin<DurableStateStore<?>,DurableStateStore<?>,DurableStateStoreProvider>
implements Extension

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.persistence.PersistencePlugin

org.apache.pekko.persistence.PersistencePlugin.PluginHolder<ScalaDsl extends Object,JavaDsl extends Object>, org.apache.pekko.persistence.PersistencePlugin.PluginHolder$

Field Summary

Fields inherited from class org.apache.pekko.persistence.PersistencePlugin

org$apache$pekko$persistence$PersistencePlugin$$ev, org$apache$pekko$persistence$PersistencePlugin$$system

Constructor Summary

Constructors

Constructor	Description
DurableStateStoreRegistry(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
static T	apply(ActorSystem system)
static T	apply(ClassicActorSystemProvider system)
static DurableStateStoreRegistry	createExtension(ExtendedActorSystem system)
final <T extends DurableStateStore<?>> T	durableStateStoreFor(String pluginId)	Scala API: Returns the pekko.persistence.state.scaladsl.DurableStateStore specified by the given configuration entry.
final <T extends DurableStateStore<?>> T	durableStateStoreFor(String pluginId, com.typesafe.config.Config runtimeConfig)	Scala API: Returns the pekko.persistence.state.scaladsl.DurableStateStore specified by the given configuration entry.
static final boolean	equals(Object other)
static DurableStateStoreRegistry	get(ActorSystem system)
static DurableStateStoreRegistry	get(ClassicActorSystemProvider system)
final <T extends DurableStateStore<?>> T	getDurableStateStoreFor(Class<T> clazz, String pluginId)	Java API: Returns the pekko.persistence.state.javadsl.DurableStateStore specified by the given configuration entry.
final <T extends DurableStateStore<?>> T	getDurableStateStoreFor(Class<T> clazz, String pluginId, com.typesafe.config.Config runtimeConfig)	Java API: Returns the pekko.persistence.state.javadsl.DurableStateStore specified by the given configuration entry.
static final int	hashCode()
static DurableStateStoreRegistry$	lookup()

Methods inherited from class org.apache.pekko.persistence.PersistencePlugin

org$apache$pekko$persistence$PersistencePlugin$$createPlugin, org$apache$pekko$persistence$PersistencePlugin$$instantiate$1, pluginFor

Methods inherited from class java.lang.Object

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

Constructor Details

DurableStateStoreRegistry

public DurableStateStoreRegistry(ExtendedActorSystem system)

Method Details

get

public static DurableStateStoreRegistry get(ActorSystem system)

get

public static DurableStateStoreRegistry get(ClassicActorSystemProvider system)

createExtension

public static DurableStateStoreRegistry createExtension(ExtendedActorSystem system)

lookup

public static DurableStateStoreRegistry$ 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)

durableStateStoreFor

public final <T extends DurableStateStore<?>> T durableStateStoreFor(String pluginId)

Scala API: Returns the pekko.persistence.state.scaladsl.DurableStateStore specified by the given configuration entry.

durableStateStoreFor

public final <T extends DurableStateStore<?>> T durableStateStoreFor(String pluginId,
 com.typesafe.config.Config runtimeConfig)

Scala API: Returns the pekko.persistence.state.scaladsl.DurableStateStore specified by the given configuration entry. The provided runtimeConfig is used to configure the plugin at runtime, taking precedence over the plugin configuration defined in the actor system configuration.

Since:

2.0.0

getDurableStateStoreFor

public final <T extends DurableStateStore<?>> T getDurableStateStoreFor(Class<T> clazz,
 String pluginId)

Java API: Returns the pekko.persistence.state.javadsl.DurableStateStore specified by the given configuration entry.

getDurableStateStoreFor

public final <T extends DurableStateStore<?>> T getDurableStateStoreFor(Class<T> clazz,
 String pluginId,
 com.typesafe.config.Config runtimeConfig)

Java API: Returns the pekko.persistence.state.javadsl.DurableStateStore specified by the given configuration entry. The provided runtimeConfig is used to configure the plugin at runtime, taking precedence over the plugin configuration defined in the actor system configuration.

Since:

2.0.0