Class JdkConnector
- java.lang.Object
-
- org.glassfish.jersey.jdk.connector.internal.JdkConnector
-
- All Implemented Interfaces:
Connector
,Inflector<ClientRequest,ClientResponse>
public class JdkConnector extends java.lang.Object implements Connector
-
-
Field Summary
Fields Modifier and Type Field Description private ConnectorConfiguration
connectorConfiguration
private HttpConnectionPool
httpConnectionPool
-
Constructor Summary
Constructors Constructor Description JdkConnector(javax.ws.rs.client.Client client, javax.ws.rs.core.Configuration config)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Field Detail
-
httpConnectionPool
private final HttpConnectionPool httpConnectionPool
-
connectorConfiguration
private final ConnectorConfiguration connectorConfiguration
-
-
Method Detail
-
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 interfaceConnector
- Specified by:
apply
in interfaceInflector<ClientRequest,ClientResponse>
- Parameters:
request
- Jersey client request to be sent.- Returns:
- Jersey client response received for the client request.
-
unwrapExecutionException
private java.lang.Throwable unwrapExecutionException(java.lang.Throwable failure)
-
apply
public java.util.concurrent.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.
-
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 java.util.Map<java.lang.String,java.util.List<java.lang.String>> translateHeaders(ClientRequest clientRequest, HttpRequest httpRequest)
-
translateResponse
private ClientResponse translateResponse(ClientRequest requestContext, HttpResponse httpResponse, java.net.URI requestUri)
-
getName
public java.lang.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.
-
-