Package org.apache.axis2.transport.testkit.http

Class JettyAsyncEndpoint<M>

java.lang.Object

org.apache.axis2.transport.testkit.http.JettyEndpoint

org.apache.axis2.transport.testkit.http.JettyAsyncEndpoint<M>

All Implemented Interfaces:

AsyncEndpoint<M>

Direct Known Subclasses:

JettyByteArrayAsyncEndpoint, JettyRESTAsyncEndpoint

public abstract class JettyAsyncEndpoint<M>
extends JettyEndpoint
implements AsyncEndpoint<M>

Constructor Summary

Constructors

Constructor	Description
JettyAsyncEndpoint()

Method Summary

Modifier and Type	Method	Description
void	clear()	Discard any pending messages.
protected abstract IncomingMessage<M>	handle(javax.servlet.http.HttpServletRequest request)
protected void	handle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
IncomingMessage<M>	waitForMessage(int timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JettyAsyncEndpoint

public JettyAsyncEndpoint()

Method Detail

handle

protected void handle(javax.servlet.http.HttpServletRequest request,
                      javax.servlet.http.HttpServletResponse response)
               throws javax.servlet.ServletException,
                      IOException

Specified by:

handle in class JettyEndpoint

Throws:

javax.servlet.ServletException

IOException

handle

protected abstract IncomingMessage<M> handle(javax.servlet.http.HttpServletRequest request)
                                      throws javax.servlet.ServletException,
                                             IOException

Throws:

javax.servlet.ServletException

IOException

clear

public void clear()
           throws Exception

Description copied from interface: AsyncEndpoint

Discard any pending messages.

Specified by:

clear in interface AsyncEndpoint<M>

Throws:

Exception

waitForMessage

public IncomingMessage<M> waitForMessage(int timeout)
                                  throws Throwable

Specified by:

waitForMessage in interface AsyncEndpoint<M>

Throws:

Throwable