From 5df8dac82e7f16792cf868f82c2229daa063bb1e Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Thu, 9 Sep 2010 20:31:05 +0200 Subject: [PATCH] Moving the Atmosphere AkkaBroadcaster dispatcher to be shared --- akka-http/src/main/scala/AkkaBroadcaster.scala | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/akka-http/src/main/scala/AkkaBroadcaster.scala b/akka-http/src/main/scala/AkkaBroadcaster.scala index 8f724ff445..ca5abc6f1d 100644 --- a/akka-http/src/main/scala/AkkaBroadcaster.scala +++ b/akka-http/src/main/scala/AkkaBroadcaster.scala @@ -9,10 +9,13 @@ 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 - +object AkkaBroadcaster { val broadcasterDispatcher = Dispatchers.fromConfig("akka.rest.comet-dispatcher") +} + +class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster { + import AkkaBroadcaster._ + name = classOf[AkkaBroadcaster].getName //FIXME should be supervised val caster = actorOf(new Actor {