Skip to content

Commit

Permalink
ensure http client does not persist.
Browse files Browse the repository at this point in the history
  • Loading branch information
wildone committed Apr 12, 2021
1 parent a69e8f1 commit c60e6aa
Showing 1 changed file with 6 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -74,8 +74,6 @@ public class AkamaiTransportHandler implements TransportHandler {
@Reference
private CryptoSupport cryptoSupport;

private HttpClient client;

public boolean canHandle(AgentConfig config) {
agentConfig = config;
String transportURI = config.getTransportURI();
Expand Down Expand Up @@ -329,13 +327,12 @@ private HttpResponse sendRequest(HttpPost request, String baseurl, String purgeu

HttpResponse response;

if(client == null) {
client = HttpClientBuilder.create()
.addInterceptorFirst(new ApacheHttpClientEdgeGridInterceptor(getClientCredential(clientAccessToken,clientToken,clientSecret,baseurl)))
.setRoutePlanner(new ApacheHttpClientEdgeGridRoutePlanner(getClientCredential(clientAccessToken,clientToken,clientSecret,baseurl)))
.setConnectionTimeToLive(1000, TimeUnit.MILLISECONDS)
.build();
}
HttpClient client = HttpClientBuilder.create()
.addInterceptorFirst(new ApacheHttpClientEdgeGridInterceptor(getClientCredential(clientAccessToken,clientToken,clientSecret,baseurl)))
.setRoutePlanner(new ApacheHttpClientEdgeGridRoutePlanner(getClientCredential(clientAccessToken,clientToken,clientSecret,baseurl)))
.setConnectionTimeToLive(1000, TimeUnit.MILLISECONDS)
.build();

try {
response = client.execute(request);
} catch (IOException e) {
Expand Down

0 comments on commit c60e6aa

Please sign in to comment.