Class HttpExchange

java.lang.Object

org.eclipse.jetty.client.HttpExchange

All Implemented Interfaces:

CyclicTimeouts.Expirable

public class HttpExchange
extends Object
implements CyclicTimeouts.Expirable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static enum	HttpExchange.State

Field Summary

Fields

Modifier and Type	Field	Description
private HttpChannel	_channel
private final HttpDestination	destination
private final List<Response.ResponseListener>	listeners
private static final Logger	LOG
private final HttpRequest	request
private Throwable	requestFailure
private HttpExchange.State	requestState
private final HttpResponse	response
private Throwable	responseFailure
private HttpExchange.State	responseState

Constructor Summary

Constructors

Constructor	Description
HttpExchange(HttpDestination destination, HttpRequest request, List<Response.ResponseListener> listeners)

Method Summary

Modifier and Type	Method	Description
boolean	abort(Throwable failure)
(package private) boolean	associate(HttpChannel channel)	Associates the given channel to this exchange.
private boolean	completeRequest(Throwable failure)
private boolean	completeResponse(Throwable failure)
(package private) void	disassociate(HttpChannel channel)
HttpConversation	getConversation()
long	getExpireNanoTime()	Returns the expiration time in nanoseconds.
private HttpChannel	getHttpChannel()
HttpRequest	getRequest()
Throwable	getRequestFailure()
HttpResponse	getResponse()
Throwable	getResponseFailure()
List<Response.ResponseListener>	getResponseListeners()
private void	notifyFailureComplete(Throwable failure)
void	proceed(Throwable failure)
boolean	requestComplete(Throwable failure)
void	resetResponse()
boolean	responseComplete(Throwable failure)
Result	terminateRequest()
Result	terminateResponse()
String	toString()

Methods inherited from class Object

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

Field Details

LOG

private static final Logger LOG

destination

private final HttpDestination destination

request

private final HttpRequest request

listeners

private final List<Response.ResponseListener> listeners

response

private final HttpResponse response

requestState

private HttpExchange.State requestState

responseState

private HttpExchange.State responseState

_channel

private HttpChannel _channel

requestFailure

private Throwable requestFailure

responseFailure

private Throwable responseFailure

Constructor Details

HttpExchange

public HttpExchange(HttpDestination destination,
 HttpRequest request,
 List<Response.ResponseListener> listeners)

Method Details

getConversation

public HttpConversation getConversation()

getRequest

public HttpRequest getRequest()

getRequestFailure

public Throwable getRequestFailure()

getResponseListeners

public List<Response.ResponseListener> getResponseListeners()

getResponse

public HttpResponse getResponse()

getResponseFailure

public Throwable getResponseFailure()

getExpireNanoTime

public long getExpireNanoTime()

Description copied from interface: CyclicTimeouts.Expirable

Returns the expiration time in nanoseconds.

The value to return must be calculated taking into account System.nanoTime(), for example:

expireNanoTime = System.nanoTime() + timeoutNanos

Returning Long.MAX_VALUE indicates that this entity does not expire.

Specified by:

getExpireNanoTime in interface CyclicTimeouts.Expirable

Returns:

the expiration time in nanoseconds, or Long.MAX_VALUE if this entity does not expire

associate

boolean associate(HttpChannel channel)

Associates the given channel to this exchange.

Works in strict collaboration with HttpChannel.associate(HttpExchange).

Parameters:

channel - the channel to associate to this exchange

Returns:

true if the channel could be associated, false otherwise

disassociate

void disassociate(HttpChannel channel)

getHttpChannel

private HttpChannel getHttpChannel()

requestComplete

public boolean requestComplete(Throwable failure)

completeRequest

private boolean completeRequest(Throwable failure)

responseComplete

public boolean responseComplete(Throwable failure)

completeResponse

private boolean completeResponse(Throwable failure)

terminateRequest

public Result terminateRequest()

terminateResponse

public Result terminateResponse()

abort

public boolean abort(Throwable failure)

notifyFailureComplete

private void notifyFailureComplete(Throwable failure)

resetResponse

public void resetResponse()

proceed

public void proceed(Throwable failure)

toString

public String toString()

Overrides:

toString in class Object