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

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

Browse source
This commit is contained in:
Viktor Klang 2012-04-25 00:51:23 +02:00
parent 1f30be1f87
commit 11c130e44e
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-actor/src/main/scala/akka/dispatch/Dispatcher.scala
View file

@ -4,7 +4,7 @@
package akka.dispatch package akka.dispatch
import akka.event.Logging.Warning import akka.event.Logging.Error
import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.atomic.AtomicReference
import akka.actor.ActorCell import akka.actor.ActorCell
import akka.util.Duration import akka.util.Duration
@ -59,7 +59,7 @@ class Dispatcher(
executorService.get() execute invocation executorService.get() execute invocation
} catch { } catch {
case e2: RejectedExecutionException ⇒ 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 throw e2
} }
} }
@ -87,7 +87,10 @@ class Dispatcher(
executorService.get() execute mbox executorService.get() execute mbox
true true
} catch { //Retry once } 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 } else false