Fix incorrect envelope in ClientSupervisor.

Signed-off-by: Yufei Cai <yufei.cai@bosch.io>
eclipse-ditto · Oct 19, 2022 · 9438959 · 9438959
1 parent 0e2259f
commit 9438959
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...vice/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ClientSupervisor.java b/...vice/src/main/java/org/eclipse/ditto/connectivity/service/messaging/ClientSupervisor.java
@@ -42,7 +42,6 @@
 import akka.cluster.sharding.ClusterSharding;
 import akka.japi.pf.DeciderBuilder;
 import akka.japi.pf.ReceiveBuilder;
-import akka.routing.ConsistentHashingRouter;
 
 /**
  * Supervisor of client actors that live in a shard region.
@@ -208,8 +207,7 @@ private void respondAndStop(final CloseConnection command) {
     private void restartIfOpen(final StopShardedActor stopShardedActor) {
         if (props != null) {
             logger.debug("Restarting connected client actor.");
-            final var envelope =
-                    new ConsistentHashingRouter.ConsistentHashableEnvelope(props, clientActorId.toString());
+            final var envelope = new ShardedBinaryEnvelope(props, clientActorId.toString());
             ClusterSharding.get(getContext().getSystem())
                     .shardRegion(ConnectivityMessagingConstants.CLIENT_SHARD_REGION)
                     .tell(envelope, ActorRef.noSender());