-
Notifications
You must be signed in to change notification settings - Fork 72
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
#37 : disable async actions on servlet < 3. Will throw an exception a…
…t runtime.
- Loading branch information
Showing
16 changed files
with
320 additions
and
161 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
72 changes: 0 additions & 72 deletions
72
stripes/src/main/java/net/sourceforge/stripes/action/AsyncResolution.java
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
95 changes: 95 additions & 0 deletions
95
stripes/src/main/java/net/sourceforge/stripes/controller/AsyncResolution.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,95 @@ | ||
| package net.sourceforge.stripes.controller; | ||
|
|
||
| import net.sourceforge.stripes.action.ActionBean; | ||
| import net.sourceforge.stripes.action.Resolution; | ||
|
|
||
| import javax.servlet.http.HttpServletRequest; | ||
| import javax.servlet.http.HttpServletResponse; | ||
| import java.lang.reflect.Constructor; | ||
| import java.lang.reflect.InvocationTargetException; | ||
| import java.lang.reflect.Method; | ||
|
|
||
| public abstract class AsyncResolution implements Resolution { | ||
|
|
||
| private static final String REQ_ATTR_NAME = "__Stripes_Async_Resolution"; | ||
| private final HttpServletRequest request; | ||
| private final HttpServletResponse response; | ||
| private final ActionBean bean; | ||
| private final Method handler; | ||
|
|
||
| private Runnable cleanupCallback; | ||
| private long timeout; | ||
|
|
||
| protected AsyncResolution(HttpServletRequest request, HttpServletResponse response, ActionBean bean, Method handler) { | ||
| this.request = request; | ||
| this.response = response; | ||
| this.bean = bean; | ||
| this.handler = handler; | ||
| request.setAttribute(REQ_ATTR_NAME, this); | ||
| } | ||
|
|
||
| public static AsyncResolution get(HttpServletRequest request) { | ||
| return (AsyncResolution)request.getAttribute(REQ_ATTR_NAME); | ||
| } | ||
|
|
||
| public void setCleanupCallback(Runnable cleanupCallback) { | ||
| this.cleanupCallback = cleanupCallback; | ||
| } | ||
|
|
||
| public void cleanup() { | ||
| if (cleanupCallback != null) { | ||
| cleanupCallback.run(); | ||
| } | ||
| } | ||
|
|
||
| public HttpServletRequest getRequest() { | ||
| return request; | ||
| } | ||
|
|
||
| public HttpServletResponse getResponse() { | ||
| return response; | ||
| } | ||
|
|
||
| @Override | ||
| public void execute(HttpServletRequest request, HttpServletResponse response) throws Exception { | ||
| // invoke the handler (start async has been done already) and let it complete... | ||
| handler.invoke(bean, this); | ||
| } | ||
|
|
||
| public abstract void complete(); | ||
|
|
||
| public abstract void complete(Resolution resolution); | ||
|
|
||
| public abstract void dispatch(String path); | ||
|
|
||
| public abstract long getTimeout(); | ||
|
|
||
| public abstract void setTimeout(long timeout); | ||
|
|
||
| public static AsyncResolution newInstance(HttpServletRequest request, HttpServletResponse response, ActionBean bean, Method handler) { | ||
| // check wether or not we're using servlet3 | ||
| try { | ||
| HttpServletRequest.class.getMethod("startAsync"); | ||
| Class<?> impl = Class.forName("net.sourceforge.stripes.controller.AsyncResolutionServlet3"); | ||
| Constructor<?> ctor = impl.getDeclaredConstructor( | ||
| HttpServletRequest.class, | ||
| HttpServletResponse.class, | ||
| ActionBean.class, | ||
| Method.class); | ||
| Object o = ctor.newInstance(request, response, bean, handler); | ||
| return (AsyncResolution)o; | ||
| } catch (NoSuchMethodException e) { | ||
| // not using servlet 3, throw exception for the moment | ||
| throw new UnsupportedOperationException("Async action beans require Servlet3+"); | ||
| } catch (ClassNotFoundException e) { | ||
| // should never happen unless bad refactor | ||
| throw new RuntimeException(e); | ||
| } catch (IllegalAccessException e) { | ||
| throw new RuntimeException(e); | ||
| } catch (InstantiationException e) { | ||
| throw new RuntimeException(e); | ||
| } catch (InvocationTargetException e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.