optimized for review

apache · May 13, 2024 · 82ff828 · 82ff828
1 parent 2a8c169
commit 82ff828
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ClusterSharding.scala b/cluster-sharding/src/main/scala/org/apache/pekko/cluster/sharding/ClusterSharding.scala
@@ -426,14 +426,12 @@ class ClusterSharding(system: ExtendedActorSystem) extends Extension {
       allocationStrategy: ShardAllocationStrategy,
       handOffStopMessage: Any): ActorRef = {
 
-    val extractShardId: ShardRegion.ExtractShardId = msg => messageExtractor.shardId(msg)
-
     internalStart(
       typeName,
       _ => entityProps,
       settings,
       extractEntityId = extractEntityIdFromExtractor(messageExtractor),
-      extractShardId = extractShardId,
+      extractShardId = msg => messageExtractor.shardId(msg),
       allocationStrategy = allocationStrategy,
       handOffStopMessage = handOffStopMessage)
   }
@@ -626,14 +624,12 @@ class ClusterSharding(system: ExtendedActorSystem) extends Extension {
       dataCenter: Optional[String],
       messageExtractor: ShardRegion.MessageExtractor): ActorRef = {
 
-    val extractShardId: ShardRegion.ExtractShardId = msg => messageExtractor.shardId(msg)
-
     startProxy(
       typeName,
       Option(role.orElse(null)),
       Option(dataCenter.orElse(null)),
       extractEntityId = extractEntityIdFromExtractor(messageExtractor),
-      extractShardId)
+      msg => messageExtractor.shardId(msg))
 
   }