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 compatibilityClusterClientSettings(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
All Methods Static Methods Instance Methods Concrete Methods 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 configurationakka.cluster.client
.int
bufferSize()
static ClusterClientSettings
create(ActorSystem system)
Java API: Create settings from the default configurationakka.cluster.client
.static ClusterClientSettings
create(com.typesafe.config.Config config)
Java API: Create settings from a configuration with the same layout as the default configurationakka.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 APIClusterClientSettings
withInitialContacts(scala.collection.immutable.Set<ActorPath> initialContacts)
Scala APIClusterClientSettings
withReconnectTimeout(scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)
ClusterClientSettings
withRefreshContactsInterval(scala.concurrent.duration.FiniteDuration refreshContactsInterval)
-
-
-
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 configurationakka.cluster.client
.- Parameters:
config
- (undocumented)- Returns:
- (undocumented)
-
create
public static ClusterClientSettings create(ActorSystem system)
Java API: Create settings from the default configurationakka.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 configurationakka.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)
-
-