Top Inners Fields Constructors Methods
org.eclipse.jetty.ee10.servlet

public Class AsyncContextState

extends Object
implements AsyncContext
Class Inheritance
All Implemented Interfaces
jakarta.servlet.AsyncContext
Imports
java.io.IOException, jakarta.servlet.AsyncContext, .AsyncEvent, .AsyncListener, .ServletContext, .ServletException, .ServletRequest, .ServletResponse, jakarta.servlet.http.HttpServletRequest, .HttpServletResponse

Nested and Inner Type Summary

Modifier and TypeClass and Description
public static class

Field Summary

Modifier and TypeField and Description
pack-priv volatile ServletChannelState

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public void
addListener(final AsyncListener
the AsyncListener to be registered
listener
,
final ServletRequest
the ServletRequest that will be included in the AsyncEvent
request
,
final ServletResponse
the ServletResponse that will be included in the AsyncEvent
response
)

Implements jakarta.servlet.AsyncContext.addListener.

Registers the given AsyncListener with the most recent asynchronous cycle that was started by a call to one of the ServletRequest#startAsync methods.
public void
addListener(AsyncListener
the AsyncListener to be registered
listener
)

Implements jakarta.servlet.AsyncContext.addListener.

Registers the given AsyncListener with the most recent asynchronous cycle that was started by a call to one of the ServletRequest#startAsync methods.
public void
complete()

Implements jakarta.servlet.AsyncContext.complete.

Completes the asynchronous operation that was started on the request that was used to initialze this AsyncContext, closing the response that was used to initialize this AsyncContext.
public <T extends AsyncListener> T
createListener(Class<T>
the AsyncListener class to instantiate
clazz
)

Implements jakarta.servlet.AsyncContext.createListener.

Instantiates the given AsyncListener class.
public void
dispatch()

Implements jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the servlet container.
public void
dispatch(String
the path of the dispatch target, scoped to the ServletContext from which this AsyncContext was initialized
path
)

Implements jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the given path.
public void
dispatch(ServletContext
the ServletContext of the dispatch target
context
,
String
the path of the dispatch target, scoped to the given ServletContext
path
)

Implements jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the given path scoped to the given context.
public ServletRequest
getRequest()

Implements jakarta.servlet.AsyncContext.getRequest.

Gets the request that was used to initialize this AsyncContext by calling ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse).
public ServletResponse
getResponse()

Implements jakarta.servlet.AsyncContext.getResponse.

Gets the response that was used to initialize this AsyncContext by calling ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse).
public long
getTimeout()

Implements jakarta.servlet.AsyncContext.getTimeout.

Gets the timeout (in milliseconds) for this AsyncContext.
public boolean
hasOriginalRequestAndResponse()

Implements jakarta.servlet.AsyncContext.hasOriginalRequestAndResponse.

Checks if this AsyncContext was initialized with the original or application-wrapped request and response objects.
public void
public void
setTimeout(long
the timeout in milliseconds
timeout
)

Implements jakarta.servlet.AsyncContext.setTimeout.

Sets the timeout (in milliseconds) for this AsyncContext.
public void
start(final Runnable
the asynchronous handler
task
)

Implements jakarta.servlet.AsyncContext.start.

Causes the container to dispatch a thread, possibly from a managed thread pool, to run the specified Runnable.
pack-priv ServletChannelState
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

_stateback to summary
pack-priv volatile ServletChannelState _state

Constructor Detail

AsyncContextStateback to summary
public AsyncContextState(ServletChannelState state)

Method Detail

addListenerback to summary
public void addListener(final AsyncListener listener, final ServletRequest request, final ServletResponse response)

Implements jakarta.servlet.AsyncContext.addListener.

Doc from jakarta.servlet.AsyncContext.addListener.

Registers the given AsyncListener with the most recent asynchronous cycle that was started by a call to one of the ServletRequest#startAsync methods.

The given AsyncListener will receive an AsyncEvent when the asynchronous cycle completes successfully, times out, results in an error, or a new asynchronous cycle is being initiated via one of the ServletRequest#startAsync methods.

AsyncListener instances will be notified in the order in which they were added.

The given ServletRequest and ServletResponse objects will be made available to the given AsyncListener via the getSuppliedRequest and getSuppliedResponse methods, respectively, of the AsyncEvent delivered to it. These objects should not be read from or written to, respectively, at the time the AsyncEvent is delivered, because additional wrapping may have occurred since the given AsyncListener was registered, but may be used in order to release any resources associated with them.

Parameters
listener:AsyncListener

the AsyncListener to be registered

request:ServletRequest

the ServletRequest that will be included in the AsyncEvent

response:ServletResponse

the ServletResponse that will be included in the AsyncEvent

Annotations
@Override
addListenerback to summary
public void addListener(AsyncListener listener)

Implements jakarta.servlet.AsyncContext.addListener.

Doc from jakarta.servlet.AsyncContext.addListener.

Registers the given AsyncListener with the most recent asynchronous cycle that was started by a call to one of the ServletRequest#startAsync methods.

The given AsyncListener will receive an AsyncEvent when the asynchronous cycle completes successfully, times out, results in an error, or a new asynchronous cycle is being initiated via one of the ServletRequest#startAsync methods.

AsyncListener instances will be notified in the order in which they were added.

If ServletRequest#startAsync(ServletRequest, ServletResponse) or ServletRequest#startAsync is called, the exact same request and response objects are available from the AsyncEvent when the AsyncListener is notified.

Parameters
listener:AsyncListener

the AsyncListener to be registered

Annotations
@Override
completeback to summary
public void complete()

Implements jakarta.servlet.AsyncContext.complete.

Doc from jakarta.servlet.AsyncContext.complete.

Completes the asynchronous operation that was started on the request that was used to initialze this AsyncContext, closing the response that was used to initialize this AsyncContext.

Any listeners of type AsyncListener that were registered with the ServletRequest for which this AsyncContext was created will be invoked at their onComplete method.

It is legal to call this method any time after a call to ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse), and before a call to one of the dispatch methods of this class. If this method is called before the container-initiated dispatch that called startAsync has returned to the container, then the call will not take effect (and any invocations of AsyncListener#onComplete(AsyncEvent) will be delayed) until after the container-initiated dispatch has returned to the container.

Annotations
@Override
createListenerback to summary
public <T extends AsyncListener> T createListener(Class<T> clazz) throws ServletException

Implements jakarta.servlet.AsyncContext.createListener.

Doc from jakarta.servlet.AsyncContext.createListener.

Instantiates the given AsyncListener class.

The returned AsyncListener instance may be further customized before it is registered with this AsyncContext via a call to one of the addListener methods.

The given AsyncListener class must define a zero argument constructor, which is used to instantiate it.

This method supports resource injection if the given clazz represents a Managed Bean. See the Jakarta EE platform and CDI specifications for additional details about Managed Beans and resource injection.

This method supports any annotations applicable to AsyncListener.

Parameters
<T>
the class of the object to instantiate
clazz:Class<T>

the AsyncListener class to instantiate

Returns:T

the new AsyncListener instance

Annotations
@Override
Exceptions
ServletException:
if the given clazz fails to be instantiated
dispatchback to summary
public void dispatch()

Implements jakarta.servlet.AsyncContext.dispatch.

Doc from jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the servlet container.

If the asynchronous cycle was started with ServletRequest#startAsync(ServletRequest, ServletResponse), and the request passed is an instance of HttpServletRequest, then the dispatch is to the URI returned by jakarta.servlet.http.HttpServletRequest#getRequestURI. Otherwise, the dispatch is to the URI of the request when it was last dispatched by the container.

The following sequence illustrates how this will work:

// REQUEST dispatch to /url/A
AsyncContext ac = request.startAsync();
...
ac.dispatch(); // ASYNC dispatch to /url/A

// REQUEST to /url/A
// FORWARD dispatch to /url/B
request.getRequestDispatcher("/url/B").forward(request,response);
// Start async operation from within the target of the FORWARD
// dispatch
ac = request.startAsync();
...
ac.dispatch(); // ASYNC dispatch to /url/A

// REQUEST to /url/A
// FORWARD dispatch to /url/B
request.getRequestDispatcher("/url/B").forward(request,response);
// Start async operation from within the target of the FORWARD
// dispatch
ac = request.startAsync(request,response);
...
ac.dispatch(); // ASYNC dispatch to /url/B

This method returns immediately after passing the request and response objects to a container managed thread, on which the dispatch operation will be performed. If this method is called before the container-initiated dispatch that called startAsync has returned to the container, the dispatch operation will be delayed until after the container-initiated dispatch has returned to the container.

The dispatcher type of the request is set to DispatcherType.ASYNC. Unlike forward dispatches, the response buffer and headers will not be reset, and it is legal to dispatch even if the response has already been committed.

Control over the request and response is delegated to the dispatch target, and the response will be closed when the dispatch target has completed execution, unless ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse) are called.

Any errors or exceptions that may occur during the execution of this method must be caught and handled by the container, as follows:

  1. Invoke, at their onError method, all AsyncListener instances registered with the ServletRequest for which this AsyncContext was created, and make the caught Throwable available via AsyncEvent#getThrowable.
  2. If none of the listeners called complete or any of the dispatch methods, perform an error dispatch with a status code equal to HttpServletResponse.SC_INTERNAL_SERVER_ERROR, and make the above Throwable available as the value of the RequestDispatcher.ERROR_EXCEPTION request attribute.
  3. If no matching error page was found, or the error page did not call complete or any of the dispatch methods, call complete.

There can be at most one asynchronous dispatch operation per asynchronous cycle, which is started by a call to one of the ServletRequest#startAsync methods. Any attempt to perform an additional asynchronous dispatch operation within the same asynchronous cycle will result in an IllegalStateException. If startAsync is subsequently called on the dispatched request, then any of the dispatch or complete methods may be called.

Annotations
@Override
dispatchback to summary
public void dispatch(String path)

Implements jakarta.servlet.AsyncContext.dispatch.

Doc from jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the given path.

The path parameter is interpreted in the same way as in ServletRequest#getRequestDispatcher(String), within the scope of the ServletContext from which this AsyncContext was initialized.

All path related query methods of the request must reflect the dispatch target, while the original request URI, context path, path info, servlet path, and query string may be recovered from the ASYNC_REQUEST_URI, ASYNC_CONTEXT_PATH, ASYNC_PATH_INFO, ASYNC_SERVLET_PATH, and ASYNC_QUERY_STRING attributes of the request. These attributes will always reflect the original path elements, even under repeated dispatches.

There can be at most one asynchronous dispatch operation per asynchronous cycle, which is started by a call to one of the ServletRequest#startAsync methods. Any attempt to perform an additional asynchronous dispatch operation within the same asynchronous cycle will result in an IllegalStateException. If startAsync is subsequently called on the dispatched request, then any of the dispatch or complete methods may be called.

See dispatch() for additional details, including error handling.

Parameters
path:String

the path of the dispatch target, scoped to the ServletContext from which this AsyncContext was initialized

Annotations
@Override
dispatchback to summary
public void dispatch(ServletContext context, String path)

Implements jakarta.servlet.AsyncContext.dispatch.

Doc from jakarta.servlet.AsyncContext.dispatch.

Dispatches the request and response objects of this AsyncContext to the given path scoped to the given context.

The path parameter is interpreted in the same way as in ServletRequest#getRequestDispatcher(String), except that it is scoped to the given context.

All path related query methods of the request must reflect the dispatch target, while the original request URI, context path, path info, servlet path, and query string may be recovered from the ASYNC_REQUEST_URI, ASYNC_CONTEXT_PATH, ASYNC_PATH_INFO, ASYNC_SERVLET_PATH, and ASYNC_QUERY_STRING attributes of the request. These attributes will always reflect the original path elements, even under repeated dispatches.

There can be at most one asynchronous dispatch operation per asynchronous cycle, which is started by a call to one of the ServletRequest#startAsync methods. Any attempt to perform an additional asynchronous dispatch operation within the same asynchronous cycle will result in an IllegalStateException. If startAsync is subsequently called on the dispatched request, then any of the dispatch or complete methods may be called.

See dispatch() for additional details, including error handling.

Parameters
context:ServletContext

the ServletContext of the dispatch target

path:String

the path of the dispatch target, scoped to the given ServletContext

Annotations
@Override
getRequestback to summary
public ServletRequest getRequest()

Implements jakarta.servlet.AsyncContext.getRequest.

Doc from jakarta.servlet.AsyncContext.getRequest.

Gets the request that was used to initialize this AsyncContext by calling ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse).

Returns:ServletRequest

the request that was used to initialize this AsyncContext

Annotations
@Override
getResponseback to summary
public ServletResponse getResponse()

Implements jakarta.servlet.AsyncContext.getResponse.

Doc from jakarta.servlet.AsyncContext.getResponse.

Gets the response that was used to initialize this AsyncContext by calling ServletRequest#startAsync() or ServletRequest#startAsync(ServletRequest, ServletResponse).

Returns:ServletResponse

the response that was used to initialize this AsyncContext

Annotations
@Override
getTimeoutback to summary
public long getTimeout()

Implements jakarta.servlet.AsyncContext.getTimeout.

Doc from jakarta.servlet.AsyncContext.getTimeout.

Gets the timeout (in milliseconds) for this AsyncContext.

This method returns the container's default timeout for asynchronous operations, or the timeout value passed to the most recent invocation of setTimeout.

A timeout value of zero or less indicates no timeout.

Returns:long

the timeout in milliseconds

Annotations
@Override
hasOriginalRequestAndResponseback to summary
public boolean hasOriginalRequestAndResponse()

Implements jakarta.servlet.AsyncContext.hasOriginalRequestAndResponse.

Doc from jakarta.servlet.AsyncContext.hasOriginalRequestAndResponse.

Checks if this AsyncContext was initialized with the original or application-wrapped request and response objects.

This information may be used by filters invoked in the outbound direction, after a request was put into asynchronous mode, to determine whether any request and/or response wrappers that they added during their inbound invocation need to be preserved for the duration of the asynchronous operation, or may be released.

Returns:boolean

true if this AsyncContext was initialized with the original request and response objects by calling ServletRequest#startAsync(), or if it was initialized by calling ServletRequest#startAsync(ServletRequest, ServletResponse), and neither the ServletRequest nor ServletResponse arguments carried any application-provided wrappers; false otherwise

Annotations
@Override
resetback to summary
public void reset()
setTimeoutback to summary
public void setTimeout(long timeout)

Implements jakarta.servlet.AsyncContext.setTimeout.

Doc from jakarta.servlet.AsyncContext.setTimeout.

Sets the timeout (in milliseconds) for this AsyncContext.

The timeout applies to this AsyncContext once the container-initiated dispatch during which one of the ServletRequest#startAsync methods was called has returned to the container.

The timeout will expire if neither the complete method nor any of the dispatch methods are called. A timeout value of zero or less indicates no timeout.

If setTimeout is not called, then the container's default timeout, which is available via a call to getTimeout, will apply.

The default value is 30000 ms.

Parameters
timeout:long

the timeout in milliseconds

Annotations
@Override
startback to summary
public void start(final Runnable task)

Implements jakarta.servlet.AsyncContext.start.

Doc from jakarta.servlet.AsyncContext.start.

Causes the container to dispatch a thread, possibly from a managed thread pool, to run the specified Runnable. The container may propagate appropriate contextual information to the Runnable.

Parameters
task:Runnable

the asynchronous handler

Annotations
@Override
stateback to summary
pack-priv ServletChannelState state()
org.eclipse.jetty.ee10.servlet back to summary

public Class AsyncContextState.WrappedAsyncListener

extends Object
implements AsyncListener
Class Inheritance
  • java.lang.Object
  • org.eclipse.jetty.ee10.servlet.AsyncContextState.WrappedAsyncListener
All Implemented Interfaces
jakarta.servlet.AsyncListener, java.util.EventListener

Field Summary

Modifier and TypeField and Description
private final AsyncListener
private final ServletRequest
private final ServletResponse

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public AsyncListener
public void
onComplete(AsyncEvent
the AsyncEvent indicating that an asynchronous operation has been completed
event
)

Implements jakarta.servlet.AsyncListener.onComplete.

Notifies this AsyncListener that an asynchronous operation has been completed.
public void
onError(AsyncEvent
the AsyncEvent indicating that an asynchronous operation has failed to complete
event
)

Implements jakarta.servlet.AsyncListener.onError.

Notifies this AsyncListener that an asynchronous operation has failed to complete.
public void
onStartAsync(AsyncEvent
the AsyncEvent indicating that a new asynchronous cycle is being initiated
event
)

Implements jakarta.servlet.AsyncListener.onStartAsync.

Notifies this AsyncListener that a new asynchronous cycle is being initiated via a call to one of the ServletRequest#startAsync methods.
public void
onTimeout(AsyncEvent
the AsyncEvent indicating that an asynchronous operation has timed out
event
)

Implements jakarta.servlet.AsyncListener.onTimeout.

Notifies this AsyncListener that an asynchronous operation has timed out.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

_listenerback to summary
private final AsyncListener _listener
_requestback to summary
private final ServletRequest _request
_responseback to summary
private final ServletResponse _response

Constructor Detail

WrappedAsyncListenerback to summary
public WrappedAsyncListener(AsyncListener listener, ServletRequest request, ServletResponse response)

Method Detail

getListenerback to summary
public AsyncListener getListener()
onCompleteback to summary
public void onComplete(AsyncEvent event) throws IOException

Implements jakarta.servlet.AsyncListener.onComplete.

Doc from jakarta.servlet.AsyncListener.onComplete.

Notifies this AsyncListener that an asynchronous operation has been completed.

The AsyncContext corresponding to the asynchronous operation that has been completed may be obtained by calling getAsyncContext on the given event.

In addition, if this AsyncListener had been registered via a call to AsyncContext#addListener(AsyncListener, ServletRequest, ServletResponse), the supplied ServletRequest and ServletResponse objects may be retrieved by calling getSuppliedRequest and getSuppliedResponse, respectively, on the given event.

Parameters
event:AsyncEvent

the AsyncEvent indicating that an asynchronous operation has been completed

Annotations
@Override
Exceptions
IOException:
if an I/O related error has occurred during the processing of the given AsyncEvent
onErrorback to summary
public void onError(AsyncEvent event) throws IOException

Implements jakarta.servlet.AsyncListener.onError.

Doc from jakarta.servlet.AsyncListener.onError.

Notifies this AsyncListener that an asynchronous operation has failed to complete.

The AsyncContext corresponding to the asynchronous operation that failed to complete may be obtained by calling getAsyncContext on the given event.

In addition, if this AsyncListener had been registered via a call to AsyncContext#addListener(AsyncListener, ServletRequest, ServletResponse), the supplied ServletRequest and ServletResponse objects may be retrieved by calling getSuppliedRequest and getSuppliedResponse, respectively, on the given event.

Parameters
event:AsyncEvent

the AsyncEvent indicating that an asynchronous operation has failed to complete

Annotations
@Override
Exceptions
IOException:
if an I/O related error has occurred during the processing of the given AsyncEvent
onStartAsyncback to summary
public void onStartAsync(AsyncEvent event) throws IOException

Implements jakarta.servlet.AsyncListener.onStartAsync.

Doc from jakarta.servlet.AsyncListener.onStartAsync.

Notifies this AsyncListener that a new asynchronous cycle is being initiated via a call to one of the ServletRequest#startAsync methods.

The AsyncContext corresponding to the asynchronous operation that is being reinitialized may be obtained by calling getAsyncContext on the given event.

In addition, if this AsyncListener had been registered via a call to AsyncContext#addListener(AsyncListener, ServletRequest, ServletResponse), the supplied ServletRequest and ServletResponse objects may be retrieved by calling getSuppliedRequest and getSuppliedResponse, respectively, on the given event.

This AsyncListener will not receive any events related to the new asynchronous cycle unless it registers itself (via a call to AsyncContext#addListener) with the AsyncContext that is delivered as part of the given AsyncEvent.

Parameters
event:AsyncEvent

the AsyncEvent indicating that a new asynchronous cycle is being initiated

Annotations
@Override
Exceptions
IOException:
if an I/O related error has occurred during the processing of the given AsyncEvent
onTimeoutback to summary
public void onTimeout(AsyncEvent event) throws IOException

Implements jakarta.servlet.AsyncListener.onTimeout.

Doc from jakarta.servlet.AsyncListener.onTimeout.

Notifies this AsyncListener that an asynchronous operation has timed out.

The AsyncContext corresponding to the asynchronous operation that has timed out may be obtained by calling getAsyncContext on the given event.

In addition, if this AsyncListener had been registered via a call to AsyncContext#addListener(AsyncListener, ServletRequest, ServletResponse), the supplied ServletRequest and ServletResponse objects may be retrieved by calling getSuppliedRequest and getSuppliedResponse, respectively, on the given event.

Parameters
event:AsyncEvent

the AsyncEvent indicating that an asynchronous operation has timed out

Annotations
@Override
Exceptions
IOException:
if an I/O related error has occurred during the processing of the given AsyncEvent