Comet - Streaming AJAX

• @Suspend
  Annotate an endpoint method with @Suspend, and any incoming requests to this endpoint will be listening for Broadcasted messages on the specified entity.

• @Broadcast
  Annotate another endpoint method with @Broadcast on the same entity and have the result of the method propagated to all listeners for this entity.

• @Cluster(Array(classOf[AkkaClusterBroadcastFilter])) { val name = "uniquename" }
  Annotate the same endpoint as @Broadcast and give it a unique name, and now your comet app is cluster aware

<web-app>
...
  <listener>
    <listener-class>se.scalablesolutions.akka.servlet.Initializer</listener-class>
  </listener>
...
</web-app>

<servlet>
  ...
  <init-param>
    <param-name>cometSupport</param-name>
    <param-value>org.atmosphere.container.CLASS_GOES_HERE</param-value>
  </init-param>
  ...
</servlet>

• BlockingIOCometSupport
• GoogleAppEngineCometSupport
• GrizzlyCometSupport
• JBossWebCometSupport
• Jetty7CometSupport
• JettyCometSupport
• Servlet30Support
• TomcatCometSupport
• WebLogicCometSupport

@Path("/pubsub/")
@Produces(Array("text/plain;charset=ISO-8859-1"))
class PubSub {
  @GET
  @Suspend
  @Path("/topic/{topic}/")
  def subscribe(@PathParam("topic") Broadcaster topic) : Broadcastable = new Broadcastable("", topic)
 
  @GET
  @Broadcast
  @Path("/topic/{topic}/{message}/")
  @Cluster(Array(classOf[AkkaClusterBroadcastFilter])) { val name = "foo" }
  def say(@PathParam("topic") Broadcaster topic, @PathParam("message") message: String): Broadcastable =
    new Broadcastable(message, topic)
}