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

Merge branch 'master' of git@github.com:jboner/akka

Browse source 
Conflicts:
	akka-actor/src/main/scala/dispatch/Dispatchers.scala
	akka-actor/src/main/scala/dispatch/MessageHandling.scala
	akka-actor/src/main/scala/util/ReflectiveAccess.scala
This commit is contained in:
Jonas Bonér 2010-09-24 22:49:28 +02:00
commit 1a5466e075
69 changed files with 2024 additions and 631 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -4,7 +4,7 @@
package se.scalablesolutions.akka.dispatch
import se.scalablesolutions.akka.actor.{Actor, ActorRef, ActorInitializationException}
import se.scalablesolutions.akka.actor.{Actor, ActorRef, Uuid, ActorInitializationException}
import se.scalablesolutions.akka.util.{SimpleLock, Duration, HashCode, Logging}
import se.scalablesolutions.akka.util.ReflectiveAccess.EnterpriseModule
import se.scalablesolutions.akka.AkkaException
@ -13,7 +13,6 @@ import org.multiverse.commitbarriers.CountDownCommitBarrier
import java.util.{Queue, List}
import java.util.concurrent._
import concurrent.forkjoin.LinkedTransferQueue
/**
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
@ -62,7 +61,7 @@ final class MessageInvocation(val receiver: ActorRef,
*/
trait MessageDispatcher extends MailboxFactory with Logging {
protected val uuids = new ConcurrentSkipListSet[String]
protected val uuids = new ConcurrentSkipListSet[Uuid]
def dispatch(invocation: MessageInvocation): Unit