Class JdkConnector

java.lang.Object

org.glassfish.jersey.jdk.connector.internal.JdkConnector

All Implemented Interfaces:

Connector, Inflector<ClientRequest, ClientResponse>

public class JdkConnector
extends Object
implements Connector

Field Summary

Fields

Modifier and Type	Field	Description
private final ConnectorConfiguration	connectorConfiguration
private final HttpConnectionPool	httpConnectionPool

Constructor Summary

Constructors

Constructor	Description
JdkConnector(javax.ws.rs.client.Client client, javax.ws.rs.core.Configuration config)

Method Summary

Modifier and Type	Method	Description
ClientResponse	apply(ClientRequest request)	Synchronously process client request into a response.
Future<?>	apply(ClientRequest request, AsyncConnectorCallback callback)	Asynchronously process client request into a response.
void	close()	Close connector and release all it's internally associated resources.
private HttpRequest	createHttpRequest(ClientRequest request)
String	getName()	Get name of current connector.
private void	send(ClientRequest request, HttpRequest httpRequest, AsyncConnectorCallback callback)
private Map<String, List<String>>	translateHeaders(ClientRequest clientRequest, HttpRequest httpRequest)
private ClientResponse	translateResponse(ClientRequest requestContext, HttpResponse httpResponse, URI requestUri)
private Throwable	unwrapExecutionException(Throwable failure)
private void	writeBufferedEntity(ClientRequest request, HttpRequest httpRequest, AsyncConnectorCallback callback)

Methods inherited from class Object

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

Field Details

httpConnectionPool

private final HttpConnectionPool httpConnectionPool

connectorConfiguration

private final ConnectorConfiguration connectorConfiguration

Constructor Details

JdkConnector

public JdkConnector(javax.ws.rs.client.Client client,
 javax.ws.rs.core.Configuration config)

Method Details

apply

public ClientResponse apply(ClientRequest request)

Description copied from interface: Connector

Synchronously process client request into a response. The method is used by Jersey client runtime to synchronously send a request and receive a response.

Specified by:

apply in interface Connector

Specified by:

apply in interface Inflector<ClientRequest, ClientResponse>

Parameters:

request - Jersey client request to be sent.

Returns:

Jersey client response received for the client request.

unwrapExecutionException

private Throwable unwrapExecutionException(Throwable failure)

apply

public Future<?> apply(ClientRequest request,
 AsyncConnectorCallback callback)

Description copied from interface: Connector

Asynchronously process client request into a response. The method is used by Jersey client runtime to asynchronously send a request and receive a response.

Specified by:

apply in interface Connector

Parameters:

request - Jersey client request to be sent.

callback - Jersey asynchronous connector callback to asynchronously receive the request processing result (either a response or a failure).

Returns:

asynchronously executed task handle.

writeBufferedEntity

private void writeBufferedEntity(ClientRequest request,
 HttpRequest httpRequest,
 AsyncConnectorCallback callback)

send

private void send(ClientRequest request,
 HttpRequest httpRequest,
 AsyncConnectorCallback callback)

createHttpRequest

private HttpRequest createHttpRequest(ClientRequest request)

translateHeaders

private Map<String, List<String>> translateHeaders(ClientRequest clientRequest,
 HttpRequest httpRequest)

translateResponse

private ClientResponse translateResponse(ClientRequest requestContext,
 HttpResponse httpResponse,
 URI requestUri)

getName

public String getName()

Description copied from interface: Connector

Get name of current connector. Should contain identification of underlying specification and optionally version number. Will be used in User-Agent header.

Specified by:

getName in interface Connector

Returns:

name of current connector. Returning null or empty string means not including this information in a generated "User-Agent" header.

close

public void close()

Description copied from interface: Connector

Close connector and release all it's internally associated resources.

Specified by:

close in interface Connector