@Path("/ps/")
public class PubSubExperiementResource
{
    @Context 
    BroadcasterFactory _broadcasterFactory;

    @Context
    AtmosphereResource _atmosphereResource;

    @Suspend
    @GET
    public String suspend() 
    {
        return "HELLO";
    }


    @POST
    public String receive( String request)
    {
        if( request.startsWith("s:") & request.length() > 2)
        {
            // subscribe
            String channelId = request.substring(2);
            Broadcaster broadcaster = _broadcasterFactory.get(channelId);

            broadcaster.addAtmosphereResource(_atmosphereResource);

return "SUBSCRIBE OK";
        }
        else if( request.startsWith("p:") & request.length() > 2)
        {
            // publish
            int i = request.indexOf(":", 2);
            String channelId = request.substring(2, i);
            String message = request.substring(i+1);
            _broadcasterFactory.get(channelId).broadcast(message);
            return "PUBLISH OK";
        }

        return "UNKNOWN COMMAND";
    }
}