@Test public void testMeteor() throws IOException, ServletException { final AtomicReference<Meteor> meteor = new AtomicReference<Meteor>(); final Servlet s = new HttpServlet() { @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { meteor.set(Meteor.lookup(req)); } }; framework.addAtmosphereHandler("/a", new ReflectorServletProcessor(s)); AtmosphereRequest request = new AtmosphereRequestImpl.Builder().pathInfo("/a").build(); framework.interceptor(new AtmosphereInterceptorAdapter() { @Override public Action inspect(AtmosphereResource r) { Meteor m = Meteor.build(r.getRequest()); return Action.CONTINUE; } }); framework.doCometSupport(request, AtmosphereResponseImpl.newInstance()); assertNotNull(meteor.get()); }
private Meteor(AtmosphereResource r, List<BroadcastFilter> l, Serializer s) { this.r = r; this.r.setSerializer(s); if (l != null) { for (BroadcastFilter f : l) { this.r.getBroadcaster().getBroadcasterConfig().addFilter(f); } } }
Meteor { private Meteor(AtmosphereResource r, List<BroadcastFilter> l, Serializer s) { this.r = r; this.r.setSerializer(s); if (l != null) { for (BroadcastFilter f : l) { this.r.getBroadcaster().getBroadcasterConfig().addFilter(f); } } } }
Meteor { private Meteor(AtmosphereResource r, List<BroadcastFilter> l, Serializer s) { this.r = r; this.r.setSerializer(s); if (l != null) { for (BroadcastFilter f : l) { this.r.getBroadcaster().getBroadcasterConfig().addFilter(f); } } } private  Meteor(AtmosphereResource r,
                   List<BroadcastFilter> l, Serializer s); }
Meteor { private Meteor(AtmosphereResource r, List<BroadcastFilter> l, Serializer s) { this.r = r; this.r.setSerializer(s); if (l != null) { for (BroadcastFilter f : l) { this.r.getBroadcaster().getBroadcasterConfig().addFilter(f); } } } private  Meteor(AtmosphereResource r,
                   List<BroadcastFilter> l, Serializer s); static Meteor lookup(HttpServletRequest r); final static Meteor build(HttpServletRequest r); final static Meteor build(HttpServletRequest r, Serializer s); final static Meteor build(HttpServletRequest req, List<BroadcastFilter> l, Serializer s); final static Meteor build(HttpServletRequest req, Broadcaster.SCOPE scope,
                                     List<BroadcastFilter> l, Serializer s); Meteor suspend(long l); Meteor resumeOnBroadcast(boolean resumeOnBroadcast); AtmosphereResource.TRANSPORT transport(); Meteor suspend(long timeout, TimeUnit timeunit); Meteor resume(); Meteor broadcast(Object o); Meteor schedule(Object o, long period); Meteor delayBroadadcast(Object o, long period); Broadcaster getBroadcaster(); void setBroadcaster(Broadcaster b); Object attachement(); void attach(Object o); Meteor addListener(AtmosphereResourceEventListener e); Meteor removeListener(AtmosphereResourceEventListener e); void destroy(); AtmosphereResource getAtmosphereResource(); AtmosphereConfig getAtmosphereConfig(); }
Meteor { private Meteor(AtmosphereResource r, List<BroadcastFilter> l, Serializer s) { this.r = r; this.r.setSerializer(s); if (l != null) { for (BroadcastFilter f : l) { this.r.getBroadcaster().getBroadcasterConfig().addFilter(f); } } } private  Meteor(AtmosphereResource r,
                   List<BroadcastFilter> l, Serializer s); static Meteor lookup(HttpServletRequest r); final static Meteor build(HttpServletRequest r); final static Meteor build(HttpServletRequest r, Serializer s); final static Meteor build(HttpServletRequest req, List<BroadcastFilter> l, Serializer s); final static Meteor build(HttpServletRequest req, Broadcaster.SCOPE scope,
                                     List<BroadcastFilter> l, Serializer s); Meteor suspend(long l); Meteor resumeOnBroadcast(boolean resumeOnBroadcast); AtmosphereResource.TRANSPORT transport(); Meteor suspend(long timeout, TimeUnit timeunit); Meteor resume(); Meteor broadcast(Object o); Meteor schedule(Object o, long period); Meteor delayBroadadcast(Object o, long period); Broadcaster getBroadcaster(); void setBroadcaster(Broadcaster b); Object attachement(); void attach(Object o); Meteor addListener(AtmosphereResourceEventListener e); Meteor removeListener(AtmosphereResourceEventListener e); void destroy(); AtmosphereResource getAtmosphereResource(); AtmosphereConfig getAtmosphereConfig();  }