public class JettyContinuationWrapper extends Object implements Continuation, org.eclipse.jetty.continuation.ContinuationListener
Constructor and Description |
---|
JettyContinuationWrapper(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse resp,
Message m) |
Modifier and Type | Method and Description |
---|---|
protected Message |
getMessage() |
Object |
getObject()
Get arbitrary object associated with the continuation for context
|
boolean |
isExpired() |
boolean |
isNew()
Is this a newly created Continuation.
|
boolean |
isPending()
Get the pending status
|
boolean |
isReadyForWrite() |
boolean |
isResumed()
Get the resumed status
|
boolean |
isTimeout()
Get the timeout status
|
void |
onComplete(org.eclipse.jetty.continuation.Continuation cont) |
void |
onTimeout(org.eclipse.jetty.continuation.Continuation cont) |
void |
reset()
Reset the continuation
|
void |
resume()
Resume a suspended request
|
void |
setObject(Object userObject)
Sets arbitrary object associated with the continuation for context
|
boolean |
suspend(long timeout)
This method will suspend the request for the timeout or until resume is
called
|
public JettyContinuationWrapper(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse resp, Message m)
public Object getObject()
Continuation
getObject
in interface Continuation
public void setObject(Object userObject)
Continuation
setObject
in interface Continuation
userObject
- An arbitrary object to associate with the continuationpublic void resume()
Continuation
resume
in interface Continuation
public boolean isNew()
Continuation
isNew
in interface Continuation
public boolean isPending()
Continuation
isPending
in interface Continuation
public boolean isResumed()
Continuation
isResumed
in interface Continuation
public boolean isExpired()
public void reset()
Continuation
reset
in interface Continuation
public boolean suspend(long timeout)
Continuation
suspend
in interface Continuation
timeout
- the suspend timeout, timeout of 0 will suspend the request indefinitely.protected Message getMessage()
public void onComplete(org.eclipse.jetty.continuation.Continuation cont)
onComplete
in interface org.eclipse.jetty.continuation.ContinuationListener
public void onTimeout(org.eclipse.jetty.continuation.Continuation cont)
onTimeout
in interface org.eclipse.jetty.continuation.ContinuationListener
public boolean isReadyForWrite()
isReadyForWrite
in interface Continuation
public boolean isTimeout()
Continuation
isTimeout
in interface Continuation
Apache CXF