public final class ClusterReceptionistSettings extends java.lang.Object implements NoSerializationVerificationNeeded
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.duration.FiniteDuration |
acceptableHeartbeatPause() |
static ClusterReceptionistSettings |
apply(ActorSystem system)
Create settings from the default configuration
akka.cluster.client.receptionist . |
static ClusterReceptionistSettings |
apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as
the default configuration
akka.cluster.client.receptionist . |
static ClusterReceptionistSettings |
create(ActorSystem system)
Java API: Create settings from the default configuration
akka.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 configuration
akka.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 API
|
ClusterReceptionistSettings |
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(scala.Option<java.lang.String> role) |
ClusterReceptionistSettings |
withRole(java.lang.String role) |
public ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
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)
public static ClusterReceptionistSettings apply(ActorSystem system)
akka.cluster.client.receptionist
.system
- (undocumented)public static ClusterReceptionistSettings apply(com.typesafe.config.Config config)
akka.cluster.client.receptionist
.config
- (undocumented)public static ClusterReceptionistSettings create(ActorSystem system)
akka.cluster.client.receptionist
.system
- (undocumented)public static ClusterReceptionistSettings create(com.typesafe.config.Config config)
akka.cluster.client.receptionist
.config
- (undocumented)public static scala.Option<java.lang.String> roleOption(java.lang.String role)
role
- (undocumented)public scala.Option<java.lang.String> role()
public int numberOfContacts()
public scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout()
public ClusterReceptionistSettings withRole(java.lang.String role)
public ClusterReceptionistSettings withRole(scala.Option<java.lang.String> role)
public ClusterReceptionistSettings withNumberOfContacts(int numberOfContacts)
public ClusterReceptionistSettings withResponseTunnelReceiveTimeout(scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
public ClusterReceptionistSettings withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)
public scala.concurrent.duration.FiniteDuration heartbeatInterval()
public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
public scala.concurrent.duration.FiniteDuration failureDetectionInterval()