public class JdkConnector extends java.lang.Object implements Connector
Modifier and Type | Field and Description |
---|---|
private ConnectorConfiguration |
connectorConfiguration |
private HttpConnectionPool |
httpConnectionPool |
Constructor and Description |
---|
JdkConnector(javax.ws.rs.client.Client client,
javax.ws.rs.core.Configuration config) |
Modifier and Type | Method and Description |
---|---|
ClientResponse |
apply(ClientRequest request)
Synchronously process client request into a response.
|
java.util.concurrent.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) |
java.lang.String |
getName()
Get name of current connector.
|
private void |
send(ClientRequest request,
HttpRequest httpRequest,
AsyncConnectorCallback callback) |
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
translateHeaders(ClientRequest clientRequest,
HttpRequest httpRequest) |
private ClientResponse |
translateResponse(ClientRequest requestContext,
HttpResponse httpResponse,
java.net.URI requestUri) |
private java.lang.Throwable |
unwrapExecutionException(java.lang.Throwable failure) |
private void |
writeBufferedEntity(ClientRequest request,
HttpRequest httpRequest,
AsyncConnectorCallback callback) |
private final HttpConnectionPool httpConnectionPool
private final ConnectorConfiguration connectorConfiguration
public JdkConnector(javax.ws.rs.client.Client client, javax.ws.rs.core.Configuration config)
public ClientResponse apply(ClientRequest request)
Connector
apply
in interface Connector
apply
in interface Inflector<ClientRequest,ClientResponse>
request
- Jersey client request to be sent.private java.lang.Throwable unwrapExecutionException(java.lang.Throwable failure)
public java.util.concurrent.Future<?> apply(ClientRequest request, AsyncConnectorCallback callback)
Connector
private void writeBufferedEntity(ClientRequest request, HttpRequest httpRequest, AsyncConnectorCallback callback)
private void send(ClientRequest request, HttpRequest httpRequest, AsyncConnectorCallback callback)
private HttpRequest createHttpRequest(ClientRequest request)
private java.util.Map<java.lang.String,java.util.List<java.lang.String>> translateHeaders(ClientRequest clientRequest, HttpRequest httpRequest)
private ClientResponse translateResponse(ClientRequest requestContext, HttpResponse httpResponse, java.net.URI requestUri)
public java.lang.String getName()
Connector