Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

The only sensible solution is to log and rethrow, nooptimal solution.

  • Loading branch information...
commit 11c130e44e159029ea47d63598c6e47f4d908eb2 1 parent 1f30be1
@viktorklang viktorklang authored
Showing with 6 additions and 3 deletions.
  1. +6 −3 akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala
View
9 akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala
@@ -4,7 +4,7 @@
package akka.dispatch
-import akka.event.Logging.Warning
+import akka.event.Logging.Error
import java.util.concurrent.atomic.AtomicReference
import akka.actor.ActorCell
import akka.util.Duration
@@ -59,7 +59,7 @@ class Dispatcher(
executorService.get() execute invocation
} catch {
case e2: RejectedExecutionException
- prerequisites.eventStream.publish(Warning("Dispatcher", this.getClass, e2.toString))
+ prerequisites.eventStream.publish(Error(e, getClass.getName, getClass, "executeTask was rejected twice!"))
throw e2
}
}
@@ -87,7 +87,10 @@ class Dispatcher(
executorService.get() execute mbox
true
} catch { //Retry once
- case e: RejectedExecutionException mbox.setAsIdle(); throw e
+ case e: RejectedExecutionException
+ mbox.setAsIdle()
+ prerequisites.eventStream.publish(Error(e, getClass.getName, getClass, "registerForExecution was rejected twice!"))
+ throw e
}
}
} else false
Please sign in to comment.
Something went wrong with that request. Please try again.