Package 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. Corresponding to the role used by the ClusterSingletonManager. If the role is not specified it's a singleton among all nodes in the cluster, and the ClusterSingletonManager must then also be configured in same way. param: dataCenter The data center of the cluster nodes where the singleton is running. If None then the same data center as current node. 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	Description
ClusterSingletonProxySettings(java.lang.String singletonName, scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, int bufferSize)
ClusterSingletonProxySettings(java.lang.String singletonName, scala.Option<java.lang.String> role, scala.Option<java.lang.String> dataCenter, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, int bufferSize)

Method Summary

Modifier and Type	Method	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>	dataCenter()
scala.Option<java.lang.String>	role()
scala.concurrent.duration.FiniteDuration	singletonIdentificationInterval()
java.lang.String	singletonName()
ClusterSingletonProxySettings	withBufferSize(int bufferSize)
ClusterSingletonProxySettings	withDataCenter(java.lang.String dataCenter)
ClusterSingletonProxySettings	withDataCenter(scala.Option<java.lang.String> dataCenter)
ClusterSingletonProxySettings	withRole(java.lang.String role)
ClusterSingletonProxySettings	withRole(scala.Option<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.Option<java.lang.String> dataCenter,
                                     scala.concurrent.duration.FiniteDuration singletonIdentificationInterval,
                                     int bufferSize)

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.

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.

create

public static ClusterSingletonProxySettings create(ActorSystem system)

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

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.

singletonName

public java.lang.String singletonName()

role

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

dataCenter

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

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)

withDataCenter

public ClusterSingletonProxySettings withDataCenter(java.lang.String dataCenter)

withDataCenter

public ClusterSingletonProxySettings withDataCenter(scala.Option<java.lang.String> dataCenter)

withSingletonIdentificationInterval

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

withBufferSize

public ClusterSingletonProxySettings withBufferSize(int bufferSize)