Class ClusterReceptionistSettings

  • All Implemented Interfaces:
    NoSerializationVerificationNeeded

    public final class ClusterReceptionistSettings
    extends java.lang.Object
    implements NoSerializationVerificationNeeded
    param: role Start the receptionist on members tagged with this role. All members are used if undefined. param: numberOfContacts The receptionist will send this number of contact points to the client param: responseTunnelReceiveTimeout The actor that tunnel response messages to the client will be stopped after this time of inactivity.
    • Constructor Detail

      • ClusterReceptionistSettings

        public ClusterReceptionistSettings​(scala.Option<java.lang.String> role,
                                           int numberOfContacts,
                                           scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
      • ClusterReceptionistSettings

        public ClusterReceptionistSettings​(scala.Option<java.lang.String> role,
                                           int numberOfContacts,
                                           scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout,
                                           scala.concurrent.duration.FiniteDuration heartbeatInterval,
                                           scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
                                           scala.concurrent.duration.FiniteDuration failureDetectionInterval)
    • Method Detail

      • apply

        public static ClusterReceptionistSettings apply​(ActorSystem system)
        Create settings from the default configuration akka.cluster.client.receptionist.
        Parameters:
        system - (undocumented)
        Returns:
        (undocumented)
      • apply

        public static ClusterReceptionistSettings apply​(com.typesafe.config.Config config)
        Create settings from a configuration with the same layout as the default configuration akka.cluster.client.receptionist.
        Parameters:
        config - (undocumented)
        Returns:
        (undocumented)
      • create

        public static ClusterReceptionistSettings create​(ActorSystem system)
        Java API: Create settings from the default configuration akka.cluster.client.receptionist.
        Parameters:
        system - (undocumented)
        Returns:
        (undocumented)
      • create

        public static ClusterReceptionistSettings create​(com.typesafe.config.Config config)
        Java API: Create settings from a configuration with the same layout as the default configuration akka.cluster.client.receptionist.
        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)
      • role

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

        public int numberOfContacts()
      • responseTunnelReceiveTimeout

        public scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout()
      • withResponseTunnelReceiveTimeout

        public ClusterReceptionistSettings withResponseTunnelReceiveTimeout​(scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)
      • withHeartbeat

        public ClusterReceptionistSettings withHeartbeat​(scala.concurrent.duration.FiniteDuration heartbeatInterval,
                                                         scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause,
                                                         scala.concurrent.duration.FiniteDuration failureDetectionInterval)
      • heartbeatInterval

        public scala.concurrent.duration.FiniteDuration heartbeatInterval()
      • acceptableHeartbeatPause

        public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()
      • failureDetectionInterval

        public scala.concurrent.duration.FiniteDuration failureDetectionInterval()