Package org.apache.pekko.cluster.client

Class ClusterReceptionistSettings

java.lang.Object

org.apache.pekko.cluster.client.ClusterReceptionistSettings

All Implemented Interfaces:

NoSerializationVerificationNeeded

public final class ClusterReceptionistSettings
extends java.lang.Object
implements NoSerializationVerificationNeeded

Deprecated.

Use Apache Pekko gRPC instead, see https://pekko.apache.org/docs/pekko/current/cluster-client.html#migration-to-pekko-grpc. Since Akka 2.6.0.

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 Summary

Constructors

Constructor	Description
ClusterReceptionistSettings(scala.Option<java.lang.String> role, int numberOfContacts, scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)	Deprecated.
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)	Deprecated.

Method Summary

Modifier and Type	Method	Description
scala.concurrent.duration.FiniteDuration	acceptableHeartbeatPause()	Deprecated.
static ClusterReceptionistSettings	apply(com.typesafe.config.Config config)	Deprecated. Create settings from a configuration with the same layout as the default configuration pekko.cluster.client.receptionist.
static ClusterReceptionistSettings	apply(ActorSystem system)	Deprecated. Create settings from the default configuration pekko.cluster.client.receptionist.
static ClusterReceptionistSettings	create(com.typesafe.config.Config config)	Deprecated. Java API: Create settings from a configuration with the same layout as the default configuration pekko.cluster.client.receptionist.
static ClusterReceptionistSettings	create(ActorSystem system)	Deprecated. Java API: Create settings from the default configuration pekko.cluster.client.receptionist.
scala.concurrent.duration.FiniteDuration	failureDetectionInterval()	Deprecated.
scala.concurrent.duration.FiniteDuration	heartbeatInterval()	Deprecated.
int	numberOfContacts()	Deprecated.
scala.concurrent.duration.FiniteDuration	responseTunnelReceiveTimeout()	Deprecated.
scala.Option<java.lang.String>	role()	Deprecated.
ClusterReceptionistSettings	withHeartbeat(scala.concurrent.duration.FiniteDuration heartbeatInterval, scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause, scala.concurrent.duration.FiniteDuration failureDetectionInterval)	Deprecated.
ClusterReceptionistSettings	withNumberOfContacts(int numberOfContacts)	Deprecated.
ClusterReceptionistSettings	withResponseTunnelReceiveTimeout(scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout)	Deprecated.
ClusterReceptionistSettings	withRole(java.lang.String role)	Deprecated.
ClusterReceptionistSettings	withRole(scala.Option<java.lang.String> role)	Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterReceptionistSettings

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

Deprecated.

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)

Deprecated.

Method Detail

apply

public static ClusterReceptionistSettings apply(ActorSystem system)

Deprecated.

Create settings from the default configuration pekko.cluster.client.receptionist.

apply

public static ClusterReceptionistSettings apply(com.typesafe.config.Config config)

Deprecated.

Create settings from a configuration with the same layout as the default configuration pekko.cluster.client.receptionist.

create

public static ClusterReceptionistSettings create(ActorSystem system)

Deprecated.

Java API: Create settings from the default configuration pekko.cluster.client.receptionist.

create

public static ClusterReceptionistSettings create(com.typesafe.config.Config config)

Deprecated.

Java API: Create settings from a configuration with the same layout as the default configuration pekko.cluster.client.receptionist.

role

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

Deprecated.

numberOfContacts

public int numberOfContacts()

Deprecated.

responseTunnelReceiveTimeout

public scala.concurrent.duration.FiniteDuration responseTunnelReceiveTimeout()

Deprecated.

withRole

public ClusterReceptionistSettings withRole(java.lang.String role)

Deprecated.

withRole

public ClusterReceptionistSettings withRole(scala.Option<java.lang.String> role)

Deprecated.

withNumberOfContacts

public ClusterReceptionistSettings withNumberOfContacts(int numberOfContacts)

Deprecated.

withResponseTunnelReceiveTimeout

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

Deprecated.

withHeartbeat

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

Deprecated.

heartbeatInterval

public scala.concurrent.duration.FiniteDuration heartbeatInterval()

Deprecated.

acceptableHeartbeatPause

public scala.concurrent.duration.FiniteDuration acceptableHeartbeatPause()

Deprecated.

failureDetectionInterval

public scala.concurrent.duration.FiniteDuration failureDetectionInterval()

Deprecated.