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

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 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(java.lang.String role)
ClusterReceptionistSettings	withRole(scala.Option<java.lang.String> role)

Methods inherited from class java.lang.Object

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

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 configuration akka.cluster.client.receptionist.

Parameters:

config - (undocumented)

Returns:

(undocumented)

create

public static ClusterReceptionistSettings create(ActorSystem system)

Java API: Create settings from the default configuration akka.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 configuration akka.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()