Top Fields Constructors Methods
io.undertow.client.ajp

pack-priv Class AjpClientExchange

extends AbstractAttachable
implements ClientExchange
Class Inheritance
All Implemented Interfaces
io.undertow.client.ClientExchange, io.undertow.util.Attachable
Imports
io.undertow.channels.DetachableStreamSinkChannel, .DetachableStreamSourceChannel, io.undertow.client.ClientCallback, .ClientConnection, .ClientExchange, .ClientRequest, .ClientResponse, .ContinueNotification, .PushCallback, io.undertow.protocols.ajp.AjpClientRequestClientStreamSinkChannel, .AjpClientResponseStreamSourceChannel, io.undertow.util.AbstractAttachable, .Headers, org.xnio.channels.StreamSinkChannel, .StreamSourceChannel, java.io.IOException
Author
Stuart Douglas

Field Summary

Modifier and TypeField and Description
private final AjpClientConnection
clientConnection

private ContinueNotification
continueNotification

private ClientResponse
continueResponse

private IOException
failedReason

private ClientCallback<ClientExchange>
readyCallback

private final ClientRequest
request

private static final int
REQUEST_TERMINATED

private AjpClientRequestClientStreamSinkChannel
requestChannel

private final boolean
requiresContinue

private ClientResponse
response

private static final int
RESPONSE_TERMINATED

private ClientCallback<ClientExchange>
responseCallback

private AjpClientResponseStreamSourceChannel
responseChannel

private int
state

Constructor Summary

AccessConstructor and Description
pack-priv
AjpClientExchange(ClientCallback<ClientExchange> readyCallback, ClientRequest request, AjpClientConnection clientConnection)

Method Summary

Modifier and TypeMethod and Description
public ClientConnection
getConnection()

Implements io.undertow.client.ClientExchange.getConnection.

public ClientResponse
getContinueResponse()

Implements io.undertow.client.ClientExchange.getContinueResponse.

public ClientRequest
getRequest()

Implements io.undertow.client.ClientExchange.getRequest.

public StreamSinkChannel
getRequestChannel()

Implements io.undertow.client.ClientExchange.getRequestChannel.

Returns the request channel that can be used to send data to the server.

public ClientResponse
getResponse()

Implements io.undertow.client.ClientExchange.getResponse.

public StreamSourceChannel
getResponseChannel()

Implements io.undertow.client.ClientExchange.getResponseChannel.

Returns the response channel that can be used to read data from the target server.

pack-priv void
invokeReadReadyCallback(final ClientExchange result)

public boolean
isRequiresContinue()

public void
setContinueHandler(ContinueNotification continueHandler)

Implements io.undertow.client.ClientExchange.setContinueHandler.

pack-priv void
setContinueResponse(ClientResponse response)

pack-priv void
setFailed(IOException e)

public void
setPushHandler(PushCallback pushCallback)

Implements io.undertow.client.ClientExchange.setPushHandler.

pack-priv void
setRequestChannel(AjpClientRequestClientStreamSinkChannel requestChannel)

pack-priv void
setResponse(ClientResponse response)

pack-priv void
setResponseChannel(AjpClientResponseStreamSourceChannel responseChannel)

public void
setResponseListener(ClientCallback<ClientExchange> listener)

Implements io.undertow.client.ClientExchange.setResponseListener.

pack-priv void
terminateRequest()

pack-priv void
terminateResponse()

Inherited from io.undertow.util.AbstractAttachable:
addToAttachmentListcreateAttachmentMapgetAttachmentgetAttachmentListputAttachmentremoveAttachment

Field Detail

clientConnectionback to summary
private final AjpClientConnection clientConnection
continueNotificationback to summary
private ContinueNotification continueNotification
continueResponseback to summary
private ClientResponse continueResponse
failedReasonback to summary
private IOException failedReason
readyCallbackback to summary
private ClientCallback<ClientExchange> readyCallback
requestback to summary
private final ClientRequest request
REQUEST_TERMINATEDback to summary
private static final int REQUEST_TERMINATED
requestChannelback to summary
private AjpClientRequestClientStreamSinkChannel requestChannel
requiresContinueback to summary
private final boolean requiresContinue
responseback to summary
private ClientResponse response
RESPONSE_TERMINATEDback to summary
private static final int RESPONSE_TERMINATED
responseCallbackback to summary
private ClientCallback<ClientExchange> responseCallback
responseChannelback to summary
private AjpClientResponseStreamSourceChannel responseChannel
stateback to summary
private int state

Constructor Detail

AjpClientExchangeback to summary
pack-priv AjpClientExchange(ClientCallback<ClientExchange> readyCallback, ClientRequest request, AjpClientConnection clientConnection)

Method Detail

getConnectionback to summary
public ClientConnection getConnection()

Implements io.undertow.client.ClientExchange.getConnection.

Returns:ClientConnection

Doc from io.undertow.client.ClientExchange.getConnection.

The underlying connection

Annotations
@Override
getContinueResponseback to summary
public ClientResponse getContinueResponse()

Implements io.undertow.client.ClientExchange.getContinueResponse.

Returns:ClientResponse

Doc from io.undertow.client.ClientExchange.getContinueResponse.

the result of a HTTP 100-continue response

Annotations
@Override
getRequestback to summary
public ClientRequest getRequest()

Implements io.undertow.client.ClientExchange.getRequest.

Annotations
@Override
getRequestChannelback to summary
public StreamSinkChannel getRequestChannel()

Implements io.undertow.client.ClientExchange.getRequestChannel.

Doc from io.undertow.client.ClientExchange.getRequestChannel.

Returns the request channel that can be used to send data to the server.

Returns:StreamSinkChannel

The request channel

Annotations
@Override
getResponseback to summary
public ClientResponse getResponse()

Implements io.undertow.client.ClientExchange.getResponse.

Returns:ClientResponse

Doc from io.undertow.client.ClientExchange.getResponse.

The client response, or null if it has not been received yet

Annotations
@Override
getResponseChannelback to summary
public StreamSourceChannel getResponseChannel()

Implements io.undertow.client.ClientExchange.getResponseChannel.

Doc from io.undertow.client.ClientExchange.getResponseChannel.

Returns the response channel that can be used to read data from the target server.

Returns:StreamSourceChannel

The response channel

Annotations
@Override
invokeReadReadyCallbackback to summary
pack-priv void invokeReadReadyCallback(final ClientExchange result)
isRequiresContinueback to summary
public boolean isRequiresContinue()
setContinueHandlerback to summary
public void setContinueHandler(ContinueNotification continueHandler)

Implements io.undertow.client.ClientExchange.setContinueHandler.

Annotations
@Override
setContinueResponseback to summary
pack-priv void setContinueResponse(ClientResponse response)
setFailedback to summary
pack-priv void setFailed(IOException e)
setPushHandlerback to summary
public void setPushHandler(PushCallback pushCallback)

Implements io.undertow.client.ClientExchange.setPushHandler.

Annotations
@Override
setRequestChannelback to summary
pack-priv void setRequestChannel(AjpClientRequestClientStreamSinkChannel requestChannel)
setResponseback to summary
pack-priv void setResponse(ClientResponse response)
setResponseChannelback to summary
pack-priv void setResponseChannel(AjpClientResponseStreamSourceChannel responseChannel)
setResponseListenerback to summary
public void setResponseListener(ClientCallback<ClientExchange> listener)

Implements io.undertow.client.ClientExchange.setResponseListener.

Annotations
@Override
terminateRequestback to summary
pack-priv void terminateRequest()
terminateResponseback to summary
pack-priv void terminateResponse()