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. If None, then any node will do. 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​(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()
      • dataCenter

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

        public scala.concurrent.duration.FiniteDuration singletonIdentificationInterval()
      • bufferSize

        public int bufferSize()
      • withSingletonIdentificationInterval

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