diff --git a/akka-http/src/main/scala/AkkaBroadcaster.scala b/akka-http/src/main/scala/AkkaBroadcaster.scala index ac15c18da0..8f724ff445 100644 --- 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