Atmosphere Sample

gistfile1.java

    
@Path("/")
@Produces("text/plain;charset=ISO-8859-1")
public class SimpleSimpleSimple {
    @GET
    @Suspend(listeners = {EventsLogger.class})
    public String subscribe() {
        return "<!--Suspended-->";
    }
}

public class EventsLogger implements AtmosphereResourceEventListener {

    public void onSuspend(final AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event){
    }

    public void onResume(AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event) {
         event.getResponse().write("Request timed out");
    }

    public void onDisconnect(AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event) {
         event.getResponse().write("User disconnected");
    }

    public void onBroadcast(AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event) {
    }

    public void onThrowable(AtmosphereResourceEvent<HttpServletRequest, HttpServletResponse> event) {
         event.getResponse().write("Error: " + event.throwable().getMessage());
    }
}