akka.persistence.multidc.testkit

Class CassandraLifecycle

java.lang.Object

akka.persistence.multidc.testkit.CassandraLifecycle

public class CassandraLifecycle
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CassandraLifecycle.AwaitPersistenceInit

Constructor Summary

Constructors

Constructor and Description
CassandraLifecycle()

Method Summary

Modifier and Type	Method and Description
static java.net.InetSocketAddress	address()
static void	awaitPersistenceInit(akka.actor.ActorSystem system)
static void	awaitPersistenceInit(akka.actor.ActorSystem system, java.lang.String journalPluginId, java.lang.String snapshotPluginId)
static java.lang.String	awaitPersistenceInit$default$2()
static java.lang.String	awaitPersistenceInit$default$3()
static com.typesafe.config.Config	config()
static void	startCassandra(java.lang.String host, int port, java.lang.String systemName, java.lang.String cassandraConfigResource)
static void	startCassandra(java.lang.String systemName, java.lang.String cassandraConfigResource)
static java.lang.String	startCassandra$default$4()
static void	stopCassandra()

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraLifecycle

public CassandraLifecycle()

Method Detail

address

public static java.net.InetSocketAddress address()

config

public static com.typesafe.config.Config config()

awaitPersistenceInit

public static void awaitPersistenceInit(akka.actor.ActorSystem system,
                                        java.lang.String journalPluginId,
                                        java.lang.String snapshotPluginId)

startCassandra

public static void startCassandra(java.lang.String systemName,
                                  java.lang.String cassandraConfigResource)

startCassandra

public static void startCassandra(java.lang.String host,
                                  int port,
                                  java.lang.String systemName,
                                  java.lang.String cassandraConfigResource)

startCassandra$default$4

public static java.lang.String startCassandra$default$4()

stopCassandra

public static void stopCassandra()

awaitPersistenceInit

public static void awaitPersistenceInit(akka.actor.ActorSystem system)

awaitPersistenceInit$default$2

public static java.lang.String awaitPersistenceInit$default$2()

awaitPersistenceInit$default$3

public static java.lang.String awaitPersistenceInit$default$3()