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.

Field Summary

Fields

Modifier and Type	Field	Description
static final PersistenceInit$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
PersistenceInit$()

Method Summary

Modifier and Type	Method	Description
CompletionStage<Done>	initializeDefaultPlugins(ClassicActorSystemProvider system, Duration timeout)	Initialize the default journal and snapshot plugins.
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

Field Details

MODULE$

public static final PersistenceInit$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

PersistenceInit$

public PersistenceInit$()

Method Details

initializeDefaultPlugins

public 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 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