Package akka.cluster.singleton

Class 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 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​(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​(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()
        Deprecated.
        Use Akka Distributed Cluster instead. Since 2.10.0.

      • singletonIdentificationInterval

        public scala.concurrent.duration.FiniteDuration singletonIdentificationInterval()

      • bufferSize

        public int bufferSize()

      • withDataCenter

        public ClusterSingletonProxySettings withDataCenter​(java.lang.String dataCenter)
        Deprecated.
        Use Akka Distributed Cluster instead. Since 2.10.0.

      • withDataCenter

        public ClusterSingletonProxySettings withDataCenter​(scala.Option<java.lang.String> dataCenter)
        Deprecated.
        Use Akka Distributed Cluster instead. Since 2.10.0.

      • withSingletonIdentificationInterval

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