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

Adding first support for config dispatchers

Browse source
This commit is contained in:
Viktor Klang 2010-08-12 16:41:54 +02:00
parent 9236796072
commit ef16b6c73a
1 changed files with 11 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-http/src/main/scala/AkkaBroadcaster.scala
View file

@ -6,11 +6,21 @@ package se.scalablesolutions.akka.comet
import org.atmosphere.cpr.{AtmosphereResourceEvent, AtmosphereResource}
import se.scalablesolutions.akka.actor.Actor._
import se.scalablesolutions.akka.actor.Actor
import se.scalablesolutions.akka.dispatch.Dispatchers
class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster {
name = classOf[AkkaBroadcaster].getName
val caster = actor { case f : Function0[_] => f() }
val broadcasterDispatcher = Dispatchers.fromConfig("akka.rest.comet-dispatcher")
//FIXME should be supervised
val caster = actorOf(new Actor {
self.dispatcher = broadcasterDispatcher
def receive = {
case f : Function0[_] => f()
}
})
override def destroy {
super.destroy