diff --git a/akka-kernel/src/main/scala/AkkaServlet.scala b/akka-kernel/src/main/scala/AkkaServlet.scala index 0538e8a625..f633835deb 100755 --- a/akka-kernel/src/main/scala/AkkaServlet.scala +++ b/akka-kernel/src/main/scala/AkkaServlet.scala @@ -78,12 +78,17 @@ class AkkaCometServlet extends org.atmosphere.cpr.AtmosphereServlet with Logging } private def loadCometSupport(fqn : String) = { - fqn match { - case s : String if s.length > 0 => Some(Class.forName(fqn) - .getConstructor(Array(classOf[AtmosphereConfig])) - .newInstance(config) - .asInstanceOf[CometSupport[_ <: AtmosphereResource[_,_]]]) - case _ => None + + log.info("Trying to load: " + fqn) + try { + Some(Class.forName(fqn) + .getConstructor(Array(classOf[AtmosphereConfig]): _*) + .newInstance(config) + .asInstanceOf[CometSupport[_ <: AtmosphereResource[_,_]]]) + } catch { + case e : Exception => + log.error(e, "Couldn't load comet support", fqn) + None } } } diff --git a/akka-kernel/src/main/scala/Kernel.scala b/akka-kernel/src/main/scala/Kernel.scala index 69813fdd18..e4f66a9050 100644 --- a/akka-kernel/src/main/scala/Kernel.scala +++ b/akka-kernel/src/main/scala/Kernel.scala @@ -70,7 +70,7 @@ object Kernel extends Logging { adapter.setServletInstance(new AkkaCometServlet) adapter.setContextPath(uri.getPath) //Using autodetection for now - //adapter.addInitParameter("cometSupport", "org.atmosphere.container.GrizzlyCometSupport") + adapter.addInitParameter("cometSupport", "org.atmosphere.container.GrizzlyCometSupport") if (HOME.isDefined) adapter.setRootFolder(HOME.get + "/deploy/root") log.info("REST service root path: [" + adapter.getRootFolder + "] and context path [" + adapter.getContextPath + "] ")