api rename

Author: sebastian-alfers

akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardRegion.scala

@@ -1296,7 +1296,7 @@ private[akka] class ShardRegion(
         loggedFullBufferWarning = true
       }
       context.system.deadLetters ! msg
-      instrumentation.onShardRegionMessageDrop(cluster.selfAddress, self, typeName)
+      instrumentation.shardRegionMessageDropped(cluster.selfAddress, self, typeName)
     } else {
       shardBuffers.append(shardId, msg, snd)
       instrumentation.onShardRegionBufferSizeIncrease(cluster.selfAddress, self, typeName)

akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/ClusterShardingInstrumentation.scala

@@ -94,8 +94,8 @@ class ClusterShardingTelemetryEnsemble(val instrumentations: Seq[ClusterSharding
       typeName: String): Unit =
     instrumentations.foreach(_.onShardRegionBufferSizeIncrease(selfAddress, shardRegionActor, typeName))
 
-  override def onShardRegionMessageDrop(selfAddress: Address, self: ActorRef, typeName: String): Unit =
-    instrumentations.foreach(_.onShardRegionMessageDrop(selfAddress, self, typeName))
+  override def shardRegionMessageDropped(selfAddress: Address, self: ActorRef, typeName: String): Unit =
+    instrumentations.foreach(_.shardRegionMessageDropped(selfAddress, self, typeName))
 
   override def dependencies: immutable.Seq[String] =
     instrumentations.flatMap(_.dependencies)
@@ -124,7 +124,7 @@ class EmptyClusterShardingInstrumentation extends ClusterShardingInstrumentation
       shardRegionActor: ActorRef,
       typeName: String): Unit = ()
 
-  override def onShardRegionMessageDrop(selfAddress: Address, self: ActorRef, typeName: String): Unit = ()
+  override def shardRegionMessageDropped(selfAddress: Address, self: ActorRef, typeName: String): Unit = ()
 
   override def dependencies: immutable.Seq[String] = Nil
 }
@@ -148,7 +148,7 @@ trait ClusterShardingInstrumentation {
   /**
    * Drop a message send to a Shard Region as the buffer is full.
    */
-  def onShardRegionMessageDrop(selfAddress: Address, self: ActorRef, typeName: String): Unit
+  def shardRegionMessageDropped(selfAddress: Address, self: ActorRef, typeName: String): Unit
 
   /**
    * Optional dependencies for this instrumentation.

akka-cluster-sharding/src/multi-jvm/scala/akka/cluster/sharding/ClusterShardingInstrumentationSpec.scala

@@ -68,7 +68,7 @@ class SpecClusterShardingTelemetry(@nowarn("msg=never used") system: ExtendedAct
     counter.incrementAndGet()
   }
 
-  override def onShardRegionMessageDrop(selfAddress: Address, self: ActorRef, typeName: String): Unit =
+  override def shardRegionMessageDropped(selfAddress: Address, self: ActorRef, typeName: String): Unit =
     dropMessageCounter.incrementAndGet()
 
   override def dependencies: Seq[String] = Nil