public abstract class JettyAsyncEndpoint<M> extends JettyEndpoint implements AsyncEndpoint<M>
Constructor and Description |
---|
JettyAsyncEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
clear()
Discard any pending messages.
|
protected abstract IncomingMessage<M> |
handle(org.mortbay.http.HttpRequest request) |
protected void |
handle(String pathParams,
org.mortbay.http.HttpRequest request,
org.mortbay.http.HttpResponse response) |
IncomingMessage<M> |
waitForMessage(int timeout) |
protected void handle(String pathParams, org.mortbay.http.HttpRequest request, org.mortbay.http.HttpResponse response) throws org.mortbay.http.HttpException, IOException
handle
in class JettyEndpoint
org.mortbay.http.HttpException
IOException
protected abstract IncomingMessage<M> handle(org.mortbay.http.HttpRequest request) throws org.mortbay.http.HttpException, IOException
org.mortbay.http.HttpException
IOException
public void clear() throws Exception
AsyncEndpoint
clear
in interface AsyncEndpoint<M>
Exception
public IncomingMessage<M> waitForMessage(int timeout) throws Throwable
waitForMessage
in interface AsyncEndpoint<M>
Throwable
Copyright © 2004-2015 The Apache Software Foundation. All Rights Reserved.