org.apache.camel.component.jetty8

Class JettyContentExchange8

java.lang.Object

org.apache.camel.component.jetty8.JettyContentExchange8

All Implemented Interfaces:

JettyContentExchange

public class JettyContentExchange8
extends Object
implements JettyContentExchange

Jetty specific exchange which keeps track of the the request and response.

Constructor Summary

Constructors

Constructor and Description
JettyContentExchange8()

Method Summary

Modifier and Type	Method and Description
void	addRequestHeader(String key, String s)
protected void	closeRequestContentSource()
protected void	doTaskCompleted()
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(Exchange exchange, JettyHttpBinding jettyBinding, org.eclipse.jetty.client.HttpClient client, AsyncCallback callback)
protected void	onConnectionFailed(Throwable ex)
protected void	onException(Throwable ex)
protected void	onExpire()
protected void	onRequestComplete()
protected void	onResponseComplete()
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)
void	setSupportRedirect(boolean supportRedirect)
void	setTimeout(long timeout)
void	setURL(String url)

Methods inherited from class java.lang.Object

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

Constructor Detail

JettyContentExchange8

public JettyContentExchange8()

Method Detail

init

public void init(Exchange exchange,
                 JettyHttpBinding jettyBinding,
                 org.eclipse.jetty.client.HttpClient client,
                 AsyncCallback callback)

Specified by:

init in interface JettyContentExchange

onRequestComplete

protected void onRequestComplete()
                          throws IOException

Throws:

IOException

onResponseComplete

protected void onResponseComplete()
                           throws IOException

Throws:

IOException

onExpire

protected void onExpire()

onException

protected void onException(Throwable ex)

onConnectionFailed

protected void onConnectionFailed(Throwable ex)

getBody

public byte[] getBody()

Specified by:

getBody in interface JettyContentExchange

getUrl

public String getUrl()

Specified by:

getUrl in interface JettyContentExchange

closeRequestContentSource

protected void closeRequestContentSource()

doTaskCompleted

protected void doTaskCompleted()

doTaskCompleted

protected void doTaskCompleted(Throwable ex)

setRequestContentType

public void setRequestContentType(String contentType)

Specified by:

setRequestContentType in interface JettyContentExchange

getResponseStatus

public int getResponseStatus()

Specified by:

getResponseStatus in interface JettyContentExchange

setMethod

public void setMethod(String method)

Specified by:

setMethod in interface JettyContentExchange

setURL

public void setURL(String url)

Specified by:

setURL in interface JettyContentExchange

setRequestContent

public void setRequestContent(byte[] byteArray)

Specified by:

setRequestContent in interface JettyContentExchange

setRequestContent

public void setRequestContent(String data,
                              String charset)
                       throws UnsupportedEncodingException

Specified by:

setRequestContent in interface JettyContentExchange

Throws:

UnsupportedEncodingException

setRequestContent

public void setRequestContent(InputStream ins)

Specified by:

setRequestContent in interface JettyContentExchange

addRequestHeader

public void addRequestHeader(String key,
                             String s)

Specified by:

addRequestHeader in interface JettyContentExchange

send

public void send(org.eclipse.jetty.client.HttpClient client)
          throws IOException

Specified by:

send in interface JettyContentExchange

Throws:

IOException

getResponseContentBytes

public byte[] getResponseContentBytes()

Specified by:

getResponseContentBytes in interface JettyContentExchange

getRequestHeaders

public Map<String,Collection<String>> getRequestHeaders()

Specified by:

getRequestHeaders in interface JettyContentExchange

getResponseHeaders

public Map<String,Collection<String>> getResponseHeaders()

Specified by:

getResponseHeaders in interface JettyContentExchange

setTimeout

public void setTimeout(long timeout)

Specified by:

setTimeout in interface JettyContentExchange

setSupportRedirect

public void setSupportRedirect(boolean supportRedirect)

Specified by:

setSupportRedirect in interface JettyContentExchange