chore: Drop the deprecated Cluster Client

.sbt-java-formatter.conf

@@ -25,7 +25,6 @@ ignored-files = [
   //pekko-cluster-sharding
   "ClusterShardingMessages.java",
   //pekko-cluster-tools
-  "ClusterClientMessages.java",
   "DistributedPubSubMessages.java",
   //pekko-cluster-typed
   "ClusterMessages.java",

actor-typed-tests/src/test/scala/org/apache/pekko/actor/typed/internal/receptionist/LocalReceptionistSpec.scala

@@ -198,10 +198,6 @@ class LocalReceptionistSpec extends ScalaTestWithActorTestKit with AnyWordSpecLi
       listing.isForKey(ServiceKeyA) should ===(true)
       listing.serviceInstances(ServiceKeyA) should be(Set())
     }
-
-    "not conflict with the ClusterClient receptionist default name" in {
-      system.systemActorOf(Behaviors.ignore, "receptionist")
-    }
   }
 }
 

cluster-tools/src/main/java/org/apache/pekko/cluster/pubsub/protobuf/msg/DistributedPubSubMessages.java

@@ -5325,7 +5325,7 @@ public interface SendOrBuilder extends
   /**
    * <pre>
    * *
-   * Send normally local, but it is also used by the ClusterClient.
+   * Send normally local
    * </pre>
    *
    * Protobuf type {@code Send}
@@ -5673,7 +5673,7 @@ protected Builder newBuilderForType(
     /**
      * <pre>
      * *
-     * Send normally local, but it is also used by the ClusterClient.
+     * Send normally local
      * </pre>
      *
      * Protobuf type {@code Send}
@@ -6210,7 +6210,7 @@ public interface SendToAllOrBuilder extends
   /**
    * <pre>
    * *
-   * SendToAll normally local, but it is also used by the ClusterClient.
+   * SendToAll normally local
    * </pre>
    *
    * Protobuf type {@code SendToAll}
@@ -6558,7 +6558,7 @@ protected Builder newBuilderForType(
     /**
      * <pre>
      * *
-     * SendToAll normally local, but it is also used by the ClusterClient.
+     * SendToAll normally local
      * </pre>
      *
      * Protobuf type {@code SendToAll}
@@ -7084,7 +7084,7 @@ public interface PublishOrBuilder extends
   /**
    * <pre>
    * *
-   * Publish normally local, but it is also used by the ClusterClient.
+   * Publish normally local
    * </pre>
    *
    * Protobuf type {@code Publish}
@@ -7392,7 +7392,7 @@ protected Builder newBuilderForType(
     /**
      * <pre>
      * *
-     * Publish normally local, but it is also used by the ClusterClient.
+     * Publish normally local
      * </pre>
      *
      * Protobuf type {@code Publish}

cluster-tools/src/main/mima-filters/1.1.x.backwards.excludes/protoc4-upgrade.excludes

@@ -16,5 +16,4 @@
 # under the License.
 
 # Issues caused by upgrading protoc to 4.29.3
-ProblemFilters.exclude[Problem]("org.apache.pekko.cluster.client.protobuf.msg.*")
 ProblemFilters.exclude[Problem]("org.apache.pekko.cluster.pubsub.protobuf.msg.*")

cluster-tools/src/main/mima-filters/2.0.x.backwards.excludes/remove-deprecated-methods.excludes

@@ -18,3 +18,65 @@
 # Remove deprecated methods
 ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.cluster.singleton.ClusterSingletonManager.setTimer*")
 ProblemFilters.exclude[DirectMissingMethodProblem]("org.apache.pekko.cluster.pubsub.DistributedPubSubSettings.this")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Internal$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Internal$HeartbeatTick$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Internal$ReconnectTimeout$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Internal$RefreshContactsTick$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Publish")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Publish$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Send")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$Send$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$SendToAll")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClient$SendToAll$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientInteraction")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientMessage")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientReceptionist")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientReceptionist$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientSettings")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientSettings$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientUnreachable")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientUnreachable$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientUp")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClientUp$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClients")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterClients$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$CheckDeadlines$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$ClientResponseTunnel")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$Contacts")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$Contacts$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$GetContacts$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$Heartbeat$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$HeartbeatRsp$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$Ping$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionist$Internal$ReceptionistShutdown$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionistSettings")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ClusterReceptionistSettings$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPointAdded")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPointAdded$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPointChange")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPointRemoved")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPointRemoved$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPoints")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.ContactPoints$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.GetClusterClients")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.GetClusterClients$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.GetContactPoints")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.GetContactPoints$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.SubscribeClusterClients")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.SubscribeClusterClients$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.SubscribeContactPoints")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.SubscribeContactPoints$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.UnsubscribeClusterClients")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.UnsubscribeClusterClients$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.UnsubscribeContactPoints")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.UnsubscribeContactPoints$")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.protobuf.ClusterClientMessageSerializer")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.protobuf.msg.ClusterClientMessages")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.protobuf.msg.ClusterClientMessages$Contacts")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.protobuf.msg.ClusterClientMessages$Contacts$Builder")
+ProblemFilters.exclude[MissingClassProblem]("org.apache.pekko.cluster.client.protobuf.msg.ClusterClientMessages$ContactsOrBuilder")

cluster-tools/src/main/protobuf/DistributedPubSubMessages.proto

@@ -50,7 +50,7 @@ message Address {
 }
 
 /**
- * Send normally local, but it is also used by the ClusterClient.
+ * Send normally local
  */
 message Send {
   required string path = 1;
@@ -59,7 +59,7 @@ message Send {
 }
 
 /**
- * SendToAll normally local, but it is also used by the ClusterClient.
+ * SendToAll normally local
  */
 message SendToAll {
   required string path = 1;
@@ -68,7 +68,7 @@ message SendToAll {
 }
 
 /**
- * Publish normally local, but it is also used by the ClusterClient.
+ * Publish normally local
  */
 message Publish {
   required string topic = 1;

cluster-tools/src/main/resources/reference.conf

@@ -54,106 +54,6 @@ pekko.actor {
   }
 }
 
-
-# //#receptionist-ext-config
-# Settings for the ClusterClientReceptionist extension
-pekko.cluster.client.receptionist {
-  # Actor name of the ClusterReceptionist actor, /system/receptionist
-  name = receptionist
-
-  # Start the receptionist on members tagged with this role.
-  # All members are used if undefined or empty.
-  role = ""
-
-  # The receptionist will send this number of contact points to the client
-  number-of-contacts = 3
-
-  # The actor that tunnel response messages to the client will be stopped
-  # after this time of inactivity.
-  response-tunnel-receive-timeout = 30s
-
-  # The id of the dispatcher to use for ClusterReceptionist actors.
-  # If specified you need to define the settings of the actual dispatcher.
-  use-dispatcher = "pekko.actor.internal-dispatcher"
-
-  # How often failure detection heartbeat messages should be received for
-  # each ClusterClient
-  heartbeat-interval = 2s
-
-  # Number of potentially lost/delayed heartbeats that will be
-  # accepted before considering it to be an anomaly.
-  # The ClusterReceptionist is using the org.apache.pekko.remote.DeadlineFailureDetector, which
-  # will trigger if there are no heartbeats within the duration
-  # heartbeat-interval + acceptable-heartbeat-pause, i.e. 15 seconds with
-  # the default settings.
-  acceptable-heartbeat-pause = 13s
-
-  # Failure detection checking interval for checking all ClusterClients
-  failure-detection-interval = 2s
-}
-# //#receptionist-ext-config
-
-# //#cluster-client-config
-# Settings for the ClusterClient
-pekko.cluster.client {
-  # Actor paths of the ClusterReceptionist actors on the servers (cluster nodes)
-  # that the client will try to contact initially. It is mandatory to specify
-  # at least one initial contact. 
-  # Comma separated full actor paths defined by a string on the form of
-  # "pekko://system@hostname:port/system/receptionist"
-  initial-contacts = []
-
-  # Interval at which the client retries to establish contact with one of 
-  # ClusterReceptionist on the servers (cluster nodes)
-  establishing-get-contacts-interval = 3s
-
-  # Interval at which the client will ask the ClusterReceptionist for
-  # new contact points to be used for next reconnect.
-  refresh-contacts-interval = 60s
-
-  # How often failure detection heartbeat messages should be sent
-  heartbeat-interval = 2s
-
-  # Number of potentially lost/delayed heartbeats that will be
-  # accepted before considering it to be an anomaly.
-  # The ClusterClient is using the org.apache.pekko.remote.DeadlineFailureDetector, which
-  # will trigger if there are no heartbeats within the duration 
-  # heartbeat-interval + acceptable-heartbeat-pause, i.e. 15 seconds with
-  # the default settings.
-  acceptable-heartbeat-pause = 13s
-
-  # If connection to the receptionist is not established the client will buffer
-  # this number of messages and deliver them the connection is established.
-  # When the buffer is full old messages will be dropped when new messages are sent
-  # via the client. Use 0 to disable buffering, i.e. messages will be dropped
-  # immediately if the location of the singleton is unknown.
-  # Maximum allowed buffer size is 10000.
-  buffer-size = 1000
-
-  # If connection to the receptionist is lost and the client has not been
-  # able to acquire a new connection for this long the client will stop itself.
-  # This duration makes it possible to watch the cluster client and react on a more permanent
-  # loss of connection with the cluster, for example by accessing some kind of
-  # service registry for an updated set of initial contacts to start a new cluster client with.
-  # If this is not wanted it can be set to "off" to disable the timeout and retry
-  # forever.
-  reconnect-timeout = off
-}
-# //#cluster-client-config
-
-# Protobuf serializer for ClusterClient messages
-pekko.actor {
-  serializers {
-    pekko-cluster-client = "org.apache.pekko.cluster.client.protobuf.ClusterClientMessageSerializer"
-  }
-  serialization-bindings {
-    "org.apache.pekko.cluster.client.ClusterClientMessage" = pekko-cluster-client
-  }
-  serialization-identifiers {
-    "org.apache.pekko.cluster.client.protobuf.ClusterClientMessageSerializer" = 15
-  }
-}
-
 # //#singleton-config
 pekko.cluster.singleton {
   # The actor name of the child singleton actor.