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.

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
scala.concurrent.Future<Done>	initializeDefaultPlugins(ClassicActorSystemProvider system, scala.concurrent.duration.FiniteDuration timeout)	Initialize the default journal and snapshot plugins.
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

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