akka.persistence.multidc.testkit

Class MultiNodeSessionProvider

java.lang.Object

akka.persistence.cassandra.ConfigSessionProvider

akka.persistence.multidc.testkit.MultiNodeSessionProvider

All Implemented Interfaces:

akka.persistence.cassandra.SessionProvider

public class MultiNodeSessionProvider
extends akka.persistence.cassandra.ConfigSessionProvider

Field Summary

Fields inherited from class akka.persistence.cassandra.ConfigSessionProvider

akka$persistence$cassandra$ConfigSessionProvider$$config, akka$persistence$cassandra$ConfigSessionProvider$$system

Constructor Summary

Constructors

Constructor and Description
MultiNodeSessionProvider(akka.actor.ActorSystem system, com.typesafe.config.Config config)

Method Summary

Modifier and Type	Method and Description
scala.concurrent.Future<scala.collection.immutable.Seq<java.net.InetSocketAddress>>	lookupContactPoints(java.lang.String clusterId, scala.concurrent.ExecutionContext ec)

Methods inherited from class akka.persistence.cassandra.ConfigSessionProvider

buildContactPoints, clusterBuilder, connect, createQueryLogger, fetchSize, jmxReportingEnabled, metricsEnabled, poolingOptions, port, protocolVersion, reconnectMaxDelay, speculativeExecution

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiNodeSessionProvider

public MultiNodeSessionProvider(akka.actor.ActorSystem system,
                                com.typesafe.config.Config config)

Method Detail

lookupContactPoints

public scala.concurrent.Future<scala.collection.immutable.Seq<java.net.InetSocketAddress>> lookupContactPoints(java.lang.String clusterId,
                                                                                                               scala.concurrent.ExecutionContext ec)

Overrides:

lookupContactPoints in class akka.persistence.cassandra.ConfigSessionProvider