Class ClusterSingletonProxySettings
- java.lang.Object
-
- org.apache.pekko.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 theClusterSingletonManager
. param: role The role of the cluster nodes where the singleton can be deployed. Corresponding to therole
used by theClusterSingletonManager
. If the role is not specified it's a singleton among all nodes in the cluster, and theClusterSingletonManager
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
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ClusterSingletonProxySettings
apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as the default configurationpekko.cluster.singleton-proxy
.static ClusterSingletonProxySettings
apply(ActorSystem system)
Create settings from the default configurationpekko.cluster.singleton-proxy
.int
bufferSize()
static ClusterSingletonProxySettings
create(com.typesafe.config.Config config)
Java API: Create settings from a configuration with the same layout as the default configurationpekko.cluster.singleton-proxy
.static ClusterSingletonProxySettings
create(ActorSystem system)
Java API: Create settings from the default configurationpekko.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)
-
-
-
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 configurationpekko.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 configurationpekko.cluster.singleton-proxy
.
-
create
public static ClusterSingletonProxySettings create(ActorSystem system)
Java API: Create settings from the default configurationpekko.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 configurationpekko.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)
-
-