raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

UnhandledMessageException extends RuntimeException. See #1453

Browse source
This commit is contained in:
Patrik Nordwall 2011-12-08 19:29:16 +01:00
parent ce128740ab
commit 1979b14061
3 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/actor/Actor.scala
View file

@ -93,7 +93,7 @@ case class ActorInterruptedException private[akka] (cause: Throwable)
/**
* This message is thrown by default when an Actors behavior doesn't match a message
*/
case class UnhandledMessageException(msg: Any, ref: ActorRef = null) extends Exception {
case class UnhandledMessageException(msg: Any, ref: ActorRef = null) extends RuntimeException {
def this(msg: String) = this(msg, null)

2
akka-docs/java/code/akka/docs/actor/MyReceivedTimeoutUntypedActor.java
View file

@ -13,7 +13,7 @@ public class MyReceivedTimeoutUntypedActor extends UntypedActor {
getContext().setReceiveTimeout(Duration.parse("30 seconds"));
}
public void onReceive(Object message) throws Exception {
public void onReceive(Object message) {
if (message.equals("Hello")) {
getSender().tell("Hello world");
} else if (message == Actors.receiveTimeout()) {

2
akka-docs/java/code/akka/docs/actor/UntypedActorSwapper.java
View file

@ -22,7 +22,7 @@ public class UntypedActorSwapper {
public static class Swapper extends UntypedActor {
LoggingAdapter log = Logging.getLogger(getContext().system(), this);
public void onReceive(Object message) throws Exception {
public void onReceive(Object message) {
if (message == SWAP) {
log.info("Hi");
getContext().become(new Procedure<Object>() {