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

Support for more durable mailboxes

Browse source
This commit is contained in:
Jonas Bonér 2010-09-27 11:59:28 +02:00
parent 91781c7414
commit 3fe641f2e4
8 changed files with 40 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/dispatch/ExecutorBasedEventDrivenDispatcher.scala
View file

@ -135,7 +135,7 @@ class ExecutorBasedEventDrivenDispatcher(
registerForExecution(mbox)
}
protected def registerForExecution(mailbox: MessageQueue with ExecutableMailbox): Unit = if (active) {
def registerForExecution(mailbox: MessageQueue with ExecutableMailbox): Unit = if (active) {
if (mailbox.dispatcherLock.tryLock()) {
try {
executor execute mailbox