fix binary compatibility

Author: Roiocam

akka-actor-typed-tests/src/test/java/jdocs/akka/typed/RouterTest.java

@@ -124,7 +124,7 @@ static Behavior<Void> showPoolRouting() {
               Routers.pool(
                   poolSize,
                   // make sure the workers are restarted if they fail
-                  Behaviors.supervise(Worker.create()).onAnyFailure(SupervisorStrategy.restart()));
+                  Behaviors.supervise(Worker.create()).onFailure(SupervisorStrategy.restart()));
           ActorRef<Worker.Command> router = context.spawn(pool, "worker-pool");
 
           for (int i = 0; i < 10; i++) {

akka-actor-typed-tests/src/test/java/jdocs/akka/typed/supervision/SupervisionCompileOnlyTest.java

@@ -33,7 +33,7 @@ public Got(int n) {
 
     // #top-level
     public static Behavior<Command> create() {
-      return Behaviors.supervise(counter(1)).onAnyFailure(SupervisorStrategy.restart());
+      return Behaviors.supervise(counter(1)).onFailure(SupervisorStrategy.restart());
     }
     // #top-level
 
@@ -105,7 +105,7 @@ static Behavior<String> parent() {
                         return Behaviors.same();
                       });
                 }))
-        .onAnyFailure(SupervisorStrategy.restart());
+        .onFailure(SupervisorStrategy.restart());
   }
   // #restart-stop-children
 
@@ -117,16 +117,16 @@ static Behavior<String> parent2() {
           final ActorRef<String> child2 = ctx.spawn(child(0), "child2");
 
           // supervision strategy inside the setup to not recreate children on restart
-          return Behaviors.<String>supervise(
-                  Behaviors.receiveMessage(
+          return Behaviors.supervise(
+                  Behaviors.<String>receiveMessage(
                       msg -> {
                         // message handling that might throw an exception
                         String[] parts = msg.split(" ");
                         child1.tell(parts[0]);
                         child2.tell(parts[1]);
                         return Behaviors.same();
                       }))
-              .onAnyFailure(SupervisorStrategy.restart().withStopChildren(false));
+              .onFailure(SupervisorStrategy.restart().withStopChildren(false));
         });
   }
   // #restart-keep-children

akka-actor-typed/src/main/scala/akka/actor/typed/Behavior.scala

@@ -118,7 +118,7 @@ abstract class ExtensibleBehavior[T] extends Behavior[T](BehaviorTags.Extensible
  * A behavior type that could be supervised, Not for user extension.
  */
 @InternalApi
-final class SuperviseBehavior[T] private[akka] (val wrapped: Behavior[T])
+class SuperviseBehavior[T] private[akka] (val wrapped: Behavior[T])
     extends Behavior[T](BehaviorTags.SuperviseBehavior) {
   private final val ThrowableClassTag = ClassTag(classOf[Throwable])
 

akka-actor-typed/src/main/scala/akka/actor/typed/javadsl/Behaviors.scala

@@ -244,8 +244,19 @@ object Behaviors {
    *      .onFailure[IndexOutOfBoundsException](SupervisorStrategy.resume) // resume for IndexOutOfBoundsException exceptions
    * }}}
    */
-  def supervise[T](wrapped: Behavior[T]): SuperviseBehavior[T] =
-    scaladsl.Behaviors.supervise(wrapped)
+  def supervise[T](wrapped: Behavior[T]): Supervise[T] =
+    new Supervise[T](wrapped)
+
+  final class Supervise[T] private[akka] (wrapped: Behavior[T]) extends SuperviseBehavior(wrapped) {
+
+    /**
+     * Specify the [[SupervisorStrategy]] to be invoked when the wrapped behavior throws.
+     *
+     * All non-fatal (see [[scala.util.control.NonFatal]]) exceptions types will be handled using the given strategy.
+     */
+    def onFailure(strategy: SupervisorStrategy): Behavior[T] =
+      onFailure(classOf[Exception], strategy)
+  }
 
   /**
    * Transform the incoming messages by placing a funnel in front of the wrapped `Behavior`: the supplied

akka-actor-typed/src/main/scala/akka/actor/typed/scaladsl/Behaviors.scala

@@ -215,8 +215,10 @@ object Behaviors {
    *      .onFailure[IndexOutOfBoundsException](SupervisorStrategy.resume) // resume for IndexOutOfBoundsException exceptions
    * }}}
    */
-  def supervise[T](wrapped: Behavior[T]): SuperviseBehavior[T] =
-    new SuperviseBehavior[T](wrapped)
+  def supervise[T](wrapped: Behavior[T]): Supervise[T] =
+    new Supervise[T](wrapped)
+
+  final class Supervise[T] private[akka] (wrapped: Behavior[T]) extends SuperviseBehavior(wrapped)
 
   /**
    * Support for scheduled `self` messages in an actor.

akka-cluster-typed/src/test/java/jdocs/akka/cluster/typed/SingletonCompileOnlyTest.java

@@ -111,7 +111,7 @@ public static void backoff() {
         singleton.init(
             SingletonActor.of(
                 Behaviors.supervise(Counter.create())
-                    .onAnyFailure(
+                    .onFailure(
                         SupervisorStrategy.restartWithBackoff(
                             Duration.ofSeconds(1), Duration.ofSeconds(10), 0.2)),
                 "GlobalCounter"));

akka-docs/src/test/java/jdocs/typed/tutorial_1/ActorHierarchyExperiments.java

@@ -111,7 +111,7 @@ private SupervisingActor(ActorContext<String> context) {
     super(context);
     child =
         context.spawn(
-            Behaviors.supervise(SupervisedActor.create()).onAnyFailure(SupervisorStrategy.restart()),
+            Behaviors.supervise(SupervisedActor.create()).onFailure(SupervisorStrategy.restart()),
             "supervised-actor");
   }
 

akka-persistence-typed-tests/src/test/java/akka/persistence/typed/javadsl/EventSourcedBehaviorJavaDslTest.java

@@ -387,7 +387,7 @@ protected void log() {
   public void workWhenWrappedInOtherBehavior() {
     Behavior<Command> behavior =
         Behaviors.supervise(counter(PersistenceId.ofUniqueId("c6")))
-            .onAnyFailure(
+            .onFailure(
                 SupervisorStrategy.restartWithBackoff(
                     Duration.ofSeconds(1), Duration.ofSeconds(10), 0.1));
     ActorRef<Command> c = testKit.spawn(behavior);