PersistenceInit

org.apache.pekko.persistence.testkit.javadsl.PersistenceInit

Test utility to initialize persistence plugins. Useful when initialization order or coordination is needed. For example to avoid creating tables concurrently.

Attributes

Source
PersistenceInit.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def initializeDefaultPlugins(system: ClassicActorSystemProvider, timeout: Duration): CompletionStage[Done]

Initialize the default journal and snapshot plugins.

Initialize the default journal and snapshot plugins.

Attributes

Returns

a CompletionStage that is completed when the initialization has completed

Source
PersistenceInit.scala
def initializePlugins(system: ClassicActorSystemProvider, journalPluginId: String, snapshotPluginId: String, timeout: Duration): CompletionStage[Done]

Initialize the given journal and snapshot plugins.

Initialize the given journal and snapshot plugins.

The snapshotPluginId can be empty ("") if snapshot plugin isn't used.

Attributes

Returns

a CompletionStage that is completed when the initialization has completed

Source
PersistenceInit.scala