Package org.apache.pekko.persistence.testkit.javadsl

Class PersistenceInit

java.lang.Object

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

public class PersistenceInit
extends Object

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

Constructor Summary

Constructors

Constructor	Description
PersistenceInit()

Method Summary

Modifier and Type	Method	Description
static CompletionStage<Done>	initializeDefaultPlugins(ClassicActorSystemProvider system, Duration timeout)	Initialize the default journal and snapshot plugins.
static CompletionStage<Done>	initializePlugins(ClassicActorSystemProvider system, String journalPluginId, String snapshotPluginId, Duration timeout)	Initialize the given journal and snapshot plugins.

Methods inherited from class java.lang.Object

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

Constructor Details

PersistenceInit

public PersistenceInit()

Method Details

initializeDefaultPlugins

public static CompletionStage<Done> initializeDefaultPlugins(ClassicActorSystemProvider system,
 Duration timeout)

Initialize the default journal and snapshot plugins.

Returns:

a CompletionStage that is completed when the initialization has completed

initializePlugins

public static CompletionStage<Done> initializePlugins(ClassicActorSystemProvider system,
 String journalPluginId,
 String snapshotPluginId,
 Duration timeout)

Initialize the given journal and snapshot plugins.

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

Returns:

a CompletionStage that is completed when the initialization has completed