Package org.apache.pekko.persistence.testkit.scaladsl

Class PersistenceInit

java.lang.Object

org.apache.pekko.persistence.testkit.scaladsl.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 scala.concurrent.Future<Done>	initializeDefaultPlugins(ClassicActorSystemProvider system, scala.concurrent.duration.FiniteDuration timeout)	Initialize the default journal and snapshot plugins.
static scala.concurrent.Future<Done>	initializePlugins(ClassicActorSystemProvider system, String journalPluginId, String snapshotPluginId, scala.concurrent.duration.FiniteDuration 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 scala.concurrent.Future<Done> initializeDefaultPlugins(ClassicActorSystemProvider system,
 scala.concurrent.duration.FiniteDuration timeout)

Initialize the default journal and snapshot plugins.

Returns:

a Future that is completed when the initialization has completed

initializePlugins

public static scala.concurrent.Future<Done> initializePlugins(ClassicActorSystemProvider system,
 String journalPluginId,
 String snapshotPluginId,
 scala.concurrent.duration.FiniteDuration timeout)

Initialize the given journal and snapshot plugins.

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

Returns:

a Future that is completed when the initialization has completed