Update example for updated Servlet 3.0
authormarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Tue, 20 Oct 2009 13:49:15 +0000 (13:49 +0000)
committermarkt <markt@13f79535-47bb-0310-9956-ffa450edef68>
Tue, 20 Oct 2009 13:49:15 +0000 (13:49 +0000)
git-svn-id: https://svn.apache.org/repos/asf/tomcat/trunk@827446 13f79535-47bb-0310-9956-ffa450edef68

webapps/examples/WEB-INF/classes/async/AsyncStockServlet.java

index a903a36..fdbe748 100644 (file)
@@ -58,7 +58,7 @@ public class AsyncStockServlet extends HttpServlet implements TickListener, Asyn
             req.getAsyncContext().complete();
         } else if (req.isAsyncSupported()) {
             AsyncContext actx = req.startAsync();
-            req.addAsyncListener(this);
+            actx.addListener(this);
             resp.setContentType("text/plain");
             clients.add(actx);
             if (this.clientcount.incrementAndGet()==1) {
@@ -104,18 +104,25 @@ public class AsyncStockServlet extends HttpServlet implements TickListener, Asyn
 
     @Override
     public void onComplete(AsyncEvent event) throws IOException {
-        if (clients.remove(event.getRequest().getAsyncContext()) && clientcount.decrementAndGet()==0) {
+        if (clients.remove(event.getAsyncContext()) && clientcount.decrementAndGet()==0) {
             ticker.removeTickListener(this);
         }
     }
 
     @Override
     public void onError(AsyncEvent event) throws IOException {
-        event.getRequest().getAsyncContext().complete();
+        event.getAsyncContext().complete();
     }
 
     @Override
     public void onTimeout(AsyncEvent event) throws IOException {
-        event.getRequest().getAsyncContext().complete();
+        event.getAsyncContext().complete();
+    }
+
+
+
+    @Override
+    public void onStartAsync(AsyncEvent event) throws IOException {
+        // NOOP
     }
 }