public class JettyContentExchange9 extends Object implements org.apache.camel.component.jetty.JettyContentExchange
Constructor and Description |
---|
JettyContentExchange9() |
Modifier and Type | Method and Description |
---|---|
void |
addRequestHeader(String key,
String s) |
protected void |
closeRequestContentSource() |
protected void |
doTaskCompleted(Throwable ex) |
byte[] |
getBody() |
Map<String,Collection<String>> |
getRequestHeaders() |
byte[] |
getResponseContentBytes() |
Map<String,Collection<String>> |
getResponseHeaders() |
int |
getResponseStatus() |
String |
getUrl() |
void |
init(org.apache.camel.Exchange exchange,
org.apache.camel.component.jetty.JettyHttpBinding jettyBinding,
org.eclipse.jetty.client.HttpClient client,
org.apache.camel.AsyncCallback callback) |
protected void |
onConnectionFailed(Throwable ex) |
protected void |
onException(Throwable ex) |
protected void |
onExpire() |
protected void |
onRequestComplete() |
protected void |
onResponseComplete(org.eclipse.jetty.client.api.Result result,
byte[] content) |
void |
send(org.eclipse.jetty.client.HttpClient client) |
void |
setMethod(String method) |
void |
setRequestContent(byte[] byteArray) |
void |
setRequestContent(InputStream ins) |
void |
setRequestContent(String data,
String charset) |
void |
setRequestContentType(String contentType) |
protected void |
setResponse(org.eclipse.jetty.client.api.Response response) |
void |
setSupportRedirect(boolean supportRedirect) |
void |
setTimeout(long timeout) |
void |
setURL(String url) |
public void init(org.apache.camel.Exchange exchange, org.apache.camel.component.jetty.JettyHttpBinding jettyBinding, org.eclipse.jetty.client.HttpClient client, org.apache.camel.AsyncCallback callback)
init
in interface org.apache.camel.component.jetty.JettyContentExchange
protected void onRequestComplete()
protected void onResponseComplete(org.eclipse.jetty.client.api.Result result, byte[] content)
protected void onExpire()
protected void onException(Throwable ex)
protected void onConnectionFailed(Throwable ex)
public byte[] getBody()
getBody
in interface org.apache.camel.component.jetty.JettyContentExchange
public String getUrl()
getUrl
in interface org.apache.camel.component.jetty.JettyContentExchange
protected void closeRequestContentSource()
protected void doTaskCompleted(Throwable ex)
public void setRequestContentType(String contentType)
setRequestContentType
in interface org.apache.camel.component.jetty.JettyContentExchange
public int getResponseStatus()
getResponseStatus
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setMethod(String method)
setMethod
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setTimeout(long timeout)
setTimeout
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setURL(String url)
setURL
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setRequestContent(byte[] byteArray)
setRequestContent
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setRequestContent(String data, String charset) throws UnsupportedEncodingException
setRequestContent
in interface org.apache.camel.component.jetty.JettyContentExchange
UnsupportedEncodingException
public void setRequestContent(InputStream ins)
setRequestContent
in interface org.apache.camel.component.jetty.JettyContentExchange
public void addRequestHeader(String key, String s)
addRequestHeader
in interface org.apache.camel.component.jetty.JettyContentExchange
public void send(org.eclipse.jetty.client.HttpClient client) throws IOException
send
in interface org.apache.camel.component.jetty.JettyContentExchange
IOException
protected void setResponse(org.eclipse.jetty.client.api.Response response)
public byte[] getResponseContentBytes()
getResponseContentBytes
in interface org.apache.camel.component.jetty.JettyContentExchange
public Map<String,Collection<String>> getRequestHeaders()
getRequestHeaders
in interface org.apache.camel.component.jetty.JettyContentExchange
public Map<String,Collection<String>> getResponseHeaders()
getResponseHeaders
in interface org.apache.camel.component.jetty.JettyContentExchange
public void setSupportRedirect(boolean supportRedirect)
setSupportRedirect
in interface org.apache.camel.component.jetty.JettyContentExchange
Apache Camel