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

changed event handler dispatcher name

Browse source
This commit is contained in:
Jonas Bonér 2011-03-14 13:38:27 +01:00
parent dd69a4b763
commit ac0273b5eb
2 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -119,12 +119,12 @@ object EventHandler extends ListenerManagement {
case class Info(instance: AnyRef, message: String = "") extends Event case class Info(instance: AnyRef, message: String = "") extends Event
case class Debug(instance: AnyRef, message: String = "") extends Event case class Debug(instance: AnyRef, message: String = "") extends Event
val error = "[ERROR] [%s] [%s] [%s] %s\n%s".intern val error = "[ERROR] [%s] [%s] [%s] %s\n%s".intern
val warning = "[WARN] [%s] [%s] [%s] %s".intern val warning = "[WARN] [%s] [%s] [%s] %s".intern
val info = "[INFO] [%s] [%s] [%s] %s".intern val info = "[INFO] [%s] [%s] [%s] %s".intern
val debug = "[DEBUG] [%s] [%s] [%s] %s".intern val debug = "[DEBUG] [%s] [%s] [%s] %s".intern
val generic = "[GENERIC] [%s] [%s]".intern val generic = "[GENERIC] [%s] [%s]".intern
val ID = "default:error:handler".intern val ID = "event:handler".intern
val EventHandlerDispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher(ID).build val EventHandlerDispatcher = Dispatchers.newExecutorBasedEventDrivenDispatcher(ID).build

6
akka-actor/src/main/scala/akka/dispatch/MessageHandling.scala
View file

@ -16,9 +16,9 @@ import akka.actor._
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a> * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/ */
final case class MessageInvocation(val receiver: ActorRef, final case class MessageInvocation(val receiver: ActorRef,
val message: Any, val message: Any,
val sender: Option[ActorRef], val sender: Option[ActorRef],
val senderFuture: Option[CompletableFuture[Any]]) { val senderFuture: Option[CompletableFuture[Any]]) {
if (receiver eq null) throw new IllegalArgumentException("Receiver can't be null") if (receiver eq null) throw new IllegalArgumentException("Receiver can't be null")
def invoke = try { def invoke = try {