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

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

Browse source
This commit is contained in:
Martin Krasser 2010-08-14 08:14:32 +02:00
commit 4e3f260bea
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()
}
}).start
override def destroy {
super.destroy