raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Unbr0ked the comet support loading

Browse source
This commit is contained in:
Viktor Klang 2009-11-18 15:05:21 +01:00
parent e421eed98b
commit 1ef733db54
2 changed files with 12 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-kernel/src/main/scala/AkkaServlet.scala
View file

@ -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
}
}
}

2
akka-kernel/src/main/scala/Kernel.scala
View file

@ -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 + "] ")