akka.cluster.singleton

Class ClusterSingletonProxySettings

java.lang.Object

akka.cluster.singleton.ClusterSingletonProxySettings

All Implemented Interfaces:

NoSerializationVerificationNeeded

public final class ClusterSingletonProxySettings
extends java.lang.Object
implements NoSerializationVerificationNeeded

param: singletonName The actor name of the singleton actor that is started by the ClusterSingletonManager. param: role The role of the cluster nodes where the singleton can be deployed. If None, then any node will do. param: singletonIdentificationInterval Interval at which the proxy will try to resolve the singleton instance. param: bufferSize If the location of the singleton is unknown the proxy will buffer this number of messages and deliver them when the singleton is identified. When the buffer is full old messages will be dropped when new messages are sent viea the proxy. Use 0 to disable buffering, i.e. messages will be dropped immediately if the location of the singleton is unknown.

Constructor Summary

Constructors

Constructor and Description
ClusterSingletonProxySettings(java.lang.String singletonName, scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, int bufferSize)

Method Summary

Modifier and Type	Method and Description
static ClusterSingletonProxySettings	apply(ActorSystem system) Create settings from the default configuration akka.cluster.singleton-proxy.
static ClusterSingletonProxySettings	apply(com.typesafe.config.Config config) Create settings from a configuration with the same layout as the default configuration akka.cluster.singleton-proxy.
int	bufferSize()
static ClusterSingletonProxySettings	create(ActorSystem system) Java API: Create settings from the default configuration akka.cluster.singleton-proxy.
static ClusterSingletonProxySettings	create(com.typesafe.config.Config config) Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.singleton-proxy.
scala.Option<java.lang.String>	role()
static scala.Option<java.lang.String>	roleOption(java.lang.String role) INTERNAL API
scala.concurrent.duration.FiniteDuration	singletonIdentificationInterval()
java.lang.String	singletonName()
ClusterSingletonProxySettings	withBufferSize(int bufferSize)
ClusterSingletonProxySettings	withRole(scala.Option<java.lang.String> role)
ClusterSingletonProxySettings	withRole(java.lang.String role)
ClusterSingletonProxySettings	withSingletonIdentificationInterval(scala.concurrent.duration.FiniteDuration singletonIdentificationInterval)
ClusterSingletonProxySettings	withSingletonName(java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterSingletonProxySettings

public ClusterSingletonProxySettings(java.lang.String singletonName,
                                     scala.Option<java.lang.String> role,
                                     scala.concurrent.duration.FiniteDuration singletonIdentificationInterval,
                                     int bufferSize)

Method Detail

apply

public static ClusterSingletonProxySettings apply(ActorSystem system)

Create settings from the default configuration akka.cluster.singleton-proxy.

Parameters:

system - (undocumented)

Returns:

(undocumented)

apply

public static ClusterSingletonProxySettings apply(com.typesafe.config.Config config)

Create settings from a configuration with the same layout as the default configuration akka.cluster.singleton-proxy.

Parameters:

config - (undocumented)

Returns:

(undocumented)

create

public static ClusterSingletonProxySettings create(ActorSystem system)

Java API: Create settings from the default configuration akka.cluster.singleton-proxy.

Parameters:

system - (undocumented)

Returns:

(undocumented)

create

public static ClusterSingletonProxySettings create(com.typesafe.config.Config config)

Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.singleton-proxy.

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)

singletonName

public java.lang.String singletonName()

role

public scala.Option<java.lang.String> role()

singletonIdentificationInterval

public scala.concurrent.duration.FiniteDuration singletonIdentificationInterval()

bufferSize

public int bufferSize()

withSingletonName

public ClusterSingletonProxySettings withSingletonName(java.lang.String name)

withRole

public ClusterSingletonProxySettings withRole(java.lang.String role)

withRole

public ClusterSingletonProxySettings withRole(scala.Option<java.lang.String> role)

withSingletonIdentificationInterval

public ClusterSingletonProxySettings withSingletonIdentificationInterval(scala.concurrent.duration.FiniteDuration singletonIdentificationInterval)

withBufferSize

public ClusterSingletonProxySettings withBufferSize(int bufferSize)