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

java.lang.Object
  extended by org.apache.axis2.transport.testkit.http.JettyEndpoint
      extended by 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
JettyAsyncEndpoint()
           
 
Method Summary
 void clear()
          Discard any pending messages.
protected abstract  IncomingMessage<M> handle(org.mortbay.http.HttpRequest request)
           
protected  void handle(java.lang.String pathParams, org.mortbay.http.HttpRequest request, org.mortbay.http.HttpResponse 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(java.lang.String pathParams,
                      org.mortbay.http.HttpRequest request,
                      org.mortbay.http.HttpResponse response)
               throws org.mortbay.http.HttpException,
                      java.io.IOException
Specified by:
handle in class JettyEndpoint
Throws:
org.mortbay.http.HttpException
java.io.IOException

handle

protected abstract IncomingMessage<M> handle(org.mortbay.http.HttpRequest request)
                                      throws org.mortbay.http.HttpException,
                                             java.io.IOException
Throws:
org.mortbay.http.HttpException
java.io.IOException

clear

public void clear()
           throws java.lang.Exception
Description copied from interface: AsyncEndpoint
Discard any pending messages.

Specified by:
clear in interface AsyncEndpoint<M>
Throws:
java.lang.Exception

waitForMessage

public IncomingMessage<M> waitForMessage(int timeout)
                                  throws java.lang.Throwable
Specified by:
waitForMessage in interface AsyncEndpoint<M>
Throws:
java.lang.Throwable


Copyright © 2004-2009 The Apache Software Foundation. All Rights Reserved.