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
Deprecated.Use Akka gRPC instead, see https://doc.akka.io/docs/akka/2.6/cluster-client.html#migration-to-akka-grpc. Since 2.6.0.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)
Deprecated.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)
Deprecated.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description scala.concurrent.duration.FiniteDuration
acceptableHeartbeatPause()
Deprecated.static ClusterClientSettings
apply(ActorSystem system)
Deprecated.static ClusterClientSettings
apply(com.typesafe.config.Config config)
Deprecated.Create settings from a configuration with the same layout as the default configurationakka.cluster.client
.int
bufferSize()
Deprecated.static ClusterClientSettings
create(ActorSystem system)
Deprecated.Java API: Create settings from the default configurationakka.cluster.client
.static ClusterClientSettings
create(com.typesafe.config.Config config)
Deprecated.Java API: Create settings from a configuration with the same layout as the default configurationakka.cluster.client
.scala.concurrent.duration.FiniteDuration
establishingGetContactsInterval()
Deprecated.scala.concurrent.duration.FiniteDuration
heartbeatInterval()
Deprecated.scala.collection.immutable.Set<ActorPath>
initialContacts()
Deprecated.scala.Option<scala.concurrent.duration.FiniteDuration>
reconnectTimeout()
Deprecated.scala.concurrent.duration.FiniteDuration
refreshContactsInterval()
Deprecated.ClusterClientSettings
withBufferSize(int bufferSize)
Deprecated.ClusterClientSettings
withEstablishingGetContactsInterval(scala.concurrent.duration.FiniteDuration establishingGetContactsInterval)
Deprecated.ClusterClientSettings
withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause)
Deprecated.ClusterClientSettings
withInitialContacts(java.util.Set<ActorPath> initialContacts)
Deprecated.Java APIClusterClientSettings
withInitialContacts(scala.collection.immutable.Set<ActorPath> initialContacts)
Deprecated.Scala APIClusterClientSettings
withReconnectTimeout(scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)
Deprecated.ClusterClientSettings
withRefreshContactsInterval(scala.concurrent.duration.FiniteDuration refreshContactsInterval)
Deprecated.
-
-
-
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)
Deprecated.
-
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)
Deprecated.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)
Deprecated.
-
apply
public static ClusterClientSettings apply(com.typesafe.config.Config config)
Deprecated.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)
Deprecated.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)
Deprecated.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()
Deprecated.
-
establishingGetContactsInterval
public scala.concurrent.duration.FiniteDuration establishingGetContactsInterval()
Deprecated.
-
refreshContactsInterval
public scala.concurrent.duration.FiniteDuration refreshContactsInterval()
Deprecated.
-
heartbeatInterval
public scala.concurrent.duration.FiniteDuration heartbeatInterval()
Deprecated.
-
acceptableHeartbeatPause
public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
Deprecated.
-
bufferSize
public int bufferSize()
Deprecated.
-
reconnectTimeout
public scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout()
Deprecated.
-
withInitialContacts
public ClusterClientSettings withInitialContacts(scala.collection.immutable.Set<ActorPath> initialContacts)
Deprecated.Scala API- Parameters:
initialContacts
- (undocumented)- Returns:
- (undocumented)
-
withInitialContacts
public ClusterClientSettings withInitialContacts(java.util.Set<ActorPath> initialContacts)
Deprecated.Java API- Parameters:
initialContacts
- (undocumented)- Returns:
- (undocumented)
-
withEstablishingGetContactsInterval
public ClusterClientSettings withEstablishingGetContactsInterval(scala.concurrent.duration.FiniteDuration establishingGetContactsInterval)
Deprecated.
-
withRefreshContactsInterval
public ClusterClientSettings withRefreshContactsInterval(scala.concurrent.duration.FiniteDuration refreshContactsInterval)
Deprecated.
-
withHeartbeat
public ClusterClientSettings withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause)
Deprecated.
-
withBufferSize
public ClusterClientSettings withBufferSize(int bufferSize)
Deprecated.
-
withReconnectTimeout
public ClusterClientSettings withReconnectTimeout(scala.Option<scala.concurrent.duration.FiniteDuration> reconnectTimeout)
Deprecated.
-
-