diff --git a/akka-typed-tests/src/test/java/akka/typed/javadsl/BehaviorBuilderTest.java b/akka-typed-tests/src/test/java/akka/typed/javadsl/BehaviorBuilderTest.java index b9294ab5f0..2275b31a55 100644 --- a/akka-typed-tests/src/test/java/akka/typed/javadsl/BehaviorBuilderTest.java +++ b/akka-typed-tests/src/test/java/akka/typed/javadsl/BehaviorBuilderTest.java @@ -43,7 +43,7 @@ public class BehaviorBuilderTest extends JUnitSuite { return Actor.same(); }) .onSignal(Terminated.class, (ctx, t) -> { - System.out.println("Terminating along with " + t.ref()); + System.out.println("Terminating along with " + t.getRef()); return stopped(); }) .build(); diff --git a/akka-typed/src/main/scala/akka/typed/MessageAndSignals.scala b/akka-typed/src/main/scala/akka/typed/MessageAndSignals.scala index 421b5a676d..e04e6a6844 100644 --- a/akka-typed/src/main/scala/akka/typed/MessageAndSignals.scala +++ b/akka-typed/src/main/scala/akka/typed/MessageAndSignals.scala @@ -7,12 +7,18 @@ package akka.typed * Envelope that is published on the eventStream for every message that is * dropped due to overfull queues. */ -final case class Dropped(msg: Any, recipient: ActorRef[Nothing]) +final case class Dropped(msg: Any, recipient: ActorRef[Nothing]) { + /** Java API */ + def getRecipient(): ActorRef[Void] = recipient.asInstanceOf[ActorRef[Void]] +} /** * Exception that an actor fails with if it does not handle a Terminated message. */ -final case class DeathPactException(ref: ActorRef[Nothing]) extends RuntimeException(s"death pact with $ref was triggered") +final case class DeathPactException(ref: ActorRef[Nothing]) extends RuntimeException(s"death pact with $ref was triggered") { + /** Java API */ + def getRef(): ActorRef[Void] = ref.asInstanceOf[ActorRef[Void]] +} /** * Envelope for dead letters. @@ -63,4 +69,8 @@ final case class Terminated(ref: ActorRef[Nothing])(failed: Throwable) extends S def wasFailed: Boolean = failed ne null def failure: Throwable = failed def failureOption: Option[Throwable] = Option(failed) + + /** Java API */ + def getRef(): ActorRef[Void] = ref.asInstanceOf[ActorRef[Void]] + }