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 pekko.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 pekko.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()
      • withSingletonIdentificationInterval

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