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 {