Fix Atmosphere integration for the new dispatchers

2010-08-13 15:31:17 +02:00 · 2010-08-13 15:31:17 +02:00 · 8b187707a6
commit 8b187707a6
parent eec2c409f1
1 changed files with 1 additions and 1 deletions
--- a/akka-http/src/main/scala/AkkaBroadcaster.scala
+++ b/akka-http/src/main/scala/AkkaBroadcaster.scala
@ -20,7 +20,7 @@ class AkkaBroadcaster extends org.atmosphere.jersey.JerseyBroadcaster {
    def receive = {
      case f : Function0[_] => f()
    }
-  })
+  }).start

  override def destroy {
    super.destroy