Examples of javax.servlet.AsyncContext.addListener()

javax.servlet.AsyncContext.addListener()
Registers the given {@link AsyncListener} with the most recentasynchronous cycle that was started by a call to one of the {@link ServletRequest#startAsync} methods.
The given AsyncListener will receive an {@link AsyncEvent} whenthe asynchronous cycle completes successfully, times out, or results in an error.
AsyncListener instances will be notified in the order in which they were added. @param listener the AsyncListener to be registered @throws IllegalStateException if this method is called afterthe container-initiated dispatch, during which one of the {@link ServletRequest#startAsync} methods was called, hasreturned to the container

    logger.info(String.format("SignalServlet::doGet() id(%s) transport(%s)", id, transport));
    response.setCharacterEncoding("x-user-defined");
    response.setHeader("Access-Control-Allow-Origin", "*");
    response.setContentType("text/" + ("sse".equals(transport) ? "event-stream" : "plain"));
    asyncContext.setTimeout(60*1000);
    asyncContext.addListener(new AsyncListener() {
      public void onStartAsync(AsyncEvent event) throws IOException {


      }


      public void onComplete(AsyncEvent event) throws IOException {

View Full Code Here

            if (req.isAsyncSupported()) {
                resp.getWriter().print("TimeoutServletGet-");
                final AsyncContext ac = req.startAsync();
                ac.setTimeout(ASYNC_TIMEOUT);
                
                ac.addListener(new TrackingListener(
                        false, completeOnTimeout, dispatchUrl));
            } else
                resp.getWriter().print("FAIL: Async unsupported");
        }
    }

View Full Code Here

            final int iter = Integer.parseInt(req.getParameter(ITER_PARAM)) - 1;
            final AsyncContext ctxt = req.startAsync();
            if (addTrackingListener) {
                TrackingListener listener =
                    new TrackingListener(completeOnError, true, null); 
                ctxt.addListener(listener);
            }
            Runnable run = new Runnable() {
                @Override
                public void run() {
                    if (iter > 0) {

View Full Code Here

            final boolean first = TrackingServlet.first;
            TrackingServlet.first = false;


            final AsyncContext ctxt = req.startAsync();
            TrackingListener listener = new TrackingListener(false, true, null); 
            ctxt.addListener(listener);
            ctxt.setTimeout(3000);


            Runnable run = new Runnable() {
                @Override
                public void run() {

View Full Code Here

                throws ServletException, IOException {
            
            final AsyncContext asyncContext =
                request.startAsync(request, response);


            asyncContext.addListener(new TrackingListener(false, false, null));


            asyncContext.start(new Runnable() {


                @Override
                public void run() {

View Full Code Here

            if (req.isAsyncSupported()) {
                resp.getWriter().print("TimeoutServletGet-");
                final AsyncContext ac = req.startAsync();
                ac.setTimeout(3000);
                
                ac.addListener(new TrackingListener(false, completeOnTimeout));
            } else
                resp.getWriter().print("FAIL: Async unsupported");
        }
    }

View Full Code Here

            final int iter = Integer.parseInt(req.getParameter(ITER_PARAM)) - 1;
            final AsyncContext ctxt = req.startAsync();
            if (addTrackingListener) {
                TrackingListener listener =
                    new TrackingListener(completeOnError, true); 
                ctxt.addListener(listener);
            }
            Runnable run = new Runnable() {
                @Override
                public void run() {
                    if (iter > 0) {

View Full Code Here

            final boolean first = TrackingServlet.first;
            TrackingServlet.first = false;


            final AsyncContext ctxt = req.startAsync();
            TrackingListener listener = new TrackingListener(false, true); 
            ctxt.addListener(listener);
            ctxt.setTimeout(3000);


            Runnable run = new Runnable() {
                @Override
                public void run() {

View Full Code Here

        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            // step 1 - start async
            AsyncContext actx = req.startAsync();
            actx.setTimeout(Long.MAX_VALUE);
            actx.addListener(new AsyncListener() {


                @Override
                public void onTimeout(AsyncEvent event) throws IOException {
                    log.info("onTimeout");

View Full Code Here

        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
            // step 1 - start async
            AsyncContext actx = req.startAsync();
            actx.setTimeout(Long.MAX_VALUE);
            actx.addListener(new AsyncListener() {


                @Override
                public void onTimeout(AsyncEvent event) throws IOException {
                    log.info("onTimeout");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.