Package akka.cluster.client

Class ClusterClientSettings

java.lang.Object

akka.cluster.client.ClusterClientSettings

All Implemented Interfaces:

NoSerializationVerificationNeeded

public final class ClusterClientSettings
extends java.lang.Object
implements NoSerializationVerificationNeeded

For binary/source compatibility

Constructor Summary

Constructors

Constructor	Description
ClusterClientSettings(scala.collection.immutable.Set<ActorPath> initialContacts, scala.concurrent.duration.FiniteDuration establishingGetContactsInterval, scala.concurrent.duration.FiniteDuration refreshContactsInterval, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, int bufferSize)	For binary/source compatibility
ClusterClientSettings(scala.collection.immutable.Set<ActorPath> initialContacts, scala.concurrent.duration.FiniteDuration establishingGetContactsInterval, scala.concurrent.duration.FiniteDuration refreshContactsInterval, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, int bufferSize, scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	acceptableHeartbeatPause()
static ClusterClientSettings	apply(ActorSystem system)
static ClusterClientSettings	apply(com.typesafe.config.Config config)	Create settings from a configuration with the same layout as the default configuration akka.cluster.client.
int	bufferSize()
static ClusterClientSettings	create(ActorSystem system)	Java API: Create settings from the default configuration akka.cluster.client.
static ClusterClientSettings	create(com.typesafe.config.Config config)	Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.client.
scala.concurrent.duration.FiniteDuration	establishingGetContactsInterval()
scala.concurrent.duration.FiniteDuration	heartbeatInterval()
scala.collection.immutable.Set<ActorPath>	initialContacts()
scala.Option<scala.concurrent.duration.FiniteDuration>	reconnectTimeout()
scala.concurrent.duration.FiniteDuration	refreshContactsInterval()
ClusterClientSettings	withBufferSize(int bufferSize)
ClusterClientSettings	withEstablishingGetContactsInterval(scala.concurrent.duration.FiniteDuration establishingGetContactsInterval)
ClusterClientSettings	withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause)
ClusterClientSettings	withInitialContacts(java.util.Set<ActorPath> initialContacts)	Java API
ClusterClientSettings	withInitialContacts(scala.collection.immutable.Set<ActorPath> initialContacts)	Scala API
ClusterClientSettings	withReconnectTimeout(scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)
ClusterClientSettings	withRefreshContactsInterval(scala.concurrent.duration.FiniteDuration refreshContactsInterval)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterClientSettings

public ClusterClientSettings(scala.collection.immutable.Set<ActorPath> initialContacts,
                             scala.concurrent.duration.FiniteDuration establishingGetContactsInterval,
                             scala.concurrent.duration.FiniteDuration refreshContactsInterval,
                             scala.concurrent.duration.FiniteDuration heartbeatInterval,
                             scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
                             int bufferSize,
                             scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)

ClusterClientSettings

public ClusterClientSettings(scala.collection.immutable.Set<ActorPath> initialContacts,
                             scala.concurrent.duration.FiniteDuration establishingGetContactsInterval,
                             scala.concurrent.duration.FiniteDuration refreshContactsInterval,
                             scala.concurrent.duration.FiniteDuration heartbeatInterval,
                             scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
                             int bufferSize)

For binary/source compatibility

Parameters:

initialContacts - (undocumented)

establishingGetContactsInterval - (undocumented)

refreshContactsInterval - (undocumented)

heartbeatInterval - (undocumented)

acceptableHeartbeatPause - (undocumented)

bufferSize - (undocumented)

Method Detail

apply

public static ClusterClientSettings apply(ActorSystem system)

apply

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

Create settings from a configuration with the same layout as the default configuration akka.cluster.client.

Parameters:

config - (undocumented)

Returns:

(undocumented)

create

public static ClusterClientSettings create(ActorSystem system)

Java API: Create settings from the default configuration akka.cluster.client.

Parameters:

system - (undocumented)

Returns:

(undocumented)

create

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

Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.client.

Parameters:

config - (undocumented)

Returns:

(undocumented)

initialContacts

public scala.collection.immutable.Set<ActorPath> initialContacts()

establishingGetContactsInterval

public scala.concurrent.duration.FiniteDuration establishingGetContactsInterval()

refreshContactsInterval

public scala.concurrent.duration.FiniteDuration refreshContactsInterval()

heartbeatInterval

public scala.concurrent.duration.FiniteDuration heartbeatInterval()

acceptableHeartbeatPause

public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()

bufferSize

public int bufferSize()

reconnectTimeout

public scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout()

withInitialContacts

public ClusterClientSettings withInitialContacts(scala.collection.immutable.Set<ActorPath> initialContacts)

Scala API

Parameters:

initialContacts - (undocumented)

Returns:

(undocumented)

withInitialContacts

public ClusterClientSettings withInitialContacts(java.util.Set<ActorPath> initialContacts)

Java API

Parameters:

initialContacts - (undocumented)

Returns:

(undocumented)

withEstablishingGetContactsInterval

public ClusterClientSettings withEstablishingGetContactsInterval(scala.concurrent.duration.FiniteDuration establishingGetContactsInterval)

withRefreshContactsInterval

public ClusterClientSettings withRefreshContactsInterval(scala.concurrent.duration.FiniteDuration refreshContactsInterval)

withHeartbeat

public ClusterClientSettings withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval,
                                           scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause)

withBufferSize

public ClusterClientSettings withBufferSize(int bufferSize)

withReconnectTimeout

public ClusterClientSettings withReconnectTimeout(scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)