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

Added reply_? that discards messages if it cannot find reply target

Browse source
This commit is contained in:
Viktor Klang 2010-04-24 14:57:32 +02:00
parent e7a5595625
commit 4f90ace880
1 changed files with 19 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

23
akka-core/src/main/scala/actor/Actor.scala
View file

@ -566,11 +566,9 @@ trait Actor extends TransactionManagement with Logging {
/**
* Use <code>reply(..)</code> to reply with a message to the original sender of the message currently
* being processed.
* Throws an IllegalStateException if unable to determine what to reply to
*/
protected[this] def reply(message: Any) = replyTo match {
case Some(Left(actor)) => actor ! message
case Some(Right(future)) => future.completeWithResult(message)
case _ => throw new IllegalStateException(
protected[this] def reply(message: Any) = if(!reply_?(message)) throw new IllegalStateException(
"\n\tNo sender in scope, can't reply. " +
"\n\tYou have probably used the '!' method to either; " +
"\n\t\t1. Send a message to a remote actor which does not have a contact address." +
@ -579,6 +577,23 @@ trait Actor extends TransactionManagement with Logging {
"\n\tIf so, switch to '!!' (or remove '@oneway') which passes on an implicit future" +
"\n\tthat will be bound by the argument passed to 'reply'." +
"\n\tAlternatively, you can use setReplyToAddress to make sure the actor can be contacted over the network.")
/**
* Use <code>reply_?(..)</code> to reply with a message to the original sender of the message currently
* being processed.
* Returns true if reply was sent, and false if unable to determine what to reply to.
*/
protected[this] def reply_?(message: Any) : Boolean = replyTo match {
case Some(Left(actor)) =>
actor ! message
true
case Some(Right(future)) =>
future.completeWithResult(message)
true
case _ =>
false
}
/**