Package akka.cluster.client
Class ClusterReceptionistSettings
- java.lang.Object
-
- akka.cluster.client.ClusterReceptionistSettings
-
- All Implemented Interfaces:
NoSerializationVerificationNeeded
public final class ClusterReceptionistSettings extends java.lang.Object implements NoSerializationVerificationNeeded
param: role Start the receptionist on members tagged with this role. All members are used if undefined. param: numberOfContacts The receptionist will send this number of contact points to the client param: responseTunnelReceiveTimeout The actor that tunnel response messages to the client will be stopped after this time of inactivity.
-
-
Constructor Summary
Constructors Constructor Description ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.concurrent.duration.FiniteDuration
acceptableHeartbeatPause()
static ClusterReceptionistSettings
apply(ActorSystem system)
static ClusterReceptionistSettings
apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as the default configurationakka.cluster.client.receptionist
.static ClusterReceptionistSettings
create(ActorSystem system)
Java API: Create settings from the default configurationakka.cluster.client.receptionist
.static ClusterReceptionistSettings
create(com.typesafe.config.Config config)
Java API: Create settings from a configuration with the same layout as the default configurationakka.cluster.client.receptionist
.scala.concurrent.duration.FiniteDuration
failureDetectionInterval()
scala.concurrent.duration.FiniteDuration
heartbeatInterval()
int
numberOfContacts()
scala.concurrent.duration.FiniteDuration
responseTunnelReceiveTimeout()
scala.Option<java.lang.String>
role()
static scala.Option<java.lang.String>
roleOption(java.lang.String role)
INTERNAL APIClusterReceptionistSettings
withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)
ClusterReceptionistSettings
withNumberOfContacts(int numberOfContacts)
ClusterReceptionistSettings
withResponseTunnelReceiveTimeout(scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
ClusterReceptionistSettings
withRole(java.lang.String role)
ClusterReceptionistSettings
withRole(scala.Option<java.lang.String> role)
-
-
-
Constructor Detail
-
ClusterReceptionistSettings
public ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
-
ClusterReceptionistSettings
public ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout, scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)
-
-
Method Detail
-
apply
public static ClusterReceptionistSettings apply(ActorSystem system)
-
apply
public static ClusterReceptionistSettings apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as the default configurationakka.cluster.client.receptionist
.- Parameters:
config
- (undocumented)- Returns:
- (undocumented)
-
create
public static ClusterReceptionistSettings create(ActorSystem system)
Java API: Create settings from the default configurationakka.cluster.client.receptionist
.- Parameters:
system
- (undocumented)- Returns:
- (undocumented)
-
create
public static ClusterReceptionistSettings create(com.typesafe.config.Config config)
Java API: Create settings from a configuration with the same layout as the default configurationakka.cluster.client.receptionist
.- Parameters:
config
- (undocumented)- Returns:
- (undocumented)
-
roleOption
public static scala.Option<java.lang.String> roleOption(java.lang.String role)
INTERNAL API- Parameters:
role
- (undocumented)- Returns:
- (undocumented)
-
role
public scala.Option<java.lang.String> role()
-
numberOfContacts
public int numberOfContacts()
-
responseTunnelReceiveTimeout
public scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout()
-
withRole
public ClusterReceptionistSettings withRole(java.lang.String role)
-
withRole
public ClusterReceptionistSettings withRole(scala.Option<java.lang.String> role)
-
withNumberOfContacts
public ClusterReceptionistSettings withNumberOfContacts(int numberOfContacts)
-
withResponseTunnelReceiveTimeout
public ClusterReceptionistSettings withResponseTunnelReceiveTimeout(scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
-
withHeartbeat
public ClusterReceptionistSettings withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)
-
heartbeatInterval
public scala.concurrent.duration.FiniteDuration heartbeatInterval()
-
acceptableHeartbeatPause
public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
-
failureDetectionInterval
public scala.concurrent.duration.FiniteDuration failureDetectionInterval()
-
-