Repository: predictionio-sdk-java Updated Branches: refs/heads/develop 6ec083fac -> 2747475a0
Upgraded to async-http-client 1.9.33 Closes #5 Project: http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/repo Commit: http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/commit/2747475a Tree: http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/tree/2747475a Diff: http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/diff/2747475a Branch: refs/heads/develop Commit: 2747475a01aacda2d2dd1da464b72d937d6eb354 Parents: 6ec083f Author: implicitdef <[email protected]> Authored: Thu Sep 6 13:30:23 2018 -0700 Committer: Donald Szeto <[email protected]> Committed: Thu Sep 6 13:31:04 2018 -0700 ---------------------------------------------------------------------- client/pom.xml | 2 +- client/src/main/java/io/prediction/BaseClient.java | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/blob/2747475a/client/pom.xml ---------------------------------------------------------------------- diff --git a/client/pom.xml b/client/pom.xml index e844bfb..4b0d89d 100644 --- a/client/pom.xml +++ b/client/pom.xml @@ -21,7 +21,7 @@ <dependency> <groupId>com.ning</groupId> <artifactId>async-http-client</artifactId> - <version>1.8.14</version> + <version>1.9.33</version> </dependency> <dependency> <groupId>com.google.code.gson</groupId> http://git-wip-us.apache.org/repos/asf/predictionio-sdk-java/blob/2747475a/client/src/main/java/io/prediction/BaseClient.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/io/prediction/BaseClient.java b/client/src/main/java/io/prediction/BaseClient.java index 80f87a8..3e350f9 100644 --- a/client/src/main/java/io/prediction/BaseClient.java +++ b/client/src/main/java/io/prediction/BaseClient.java @@ -73,11 +73,11 @@ public abstract class BaseClient implements Closeable { this.apiUrl = apiURL; // Async HTTP client config AsyncHttpClientConfig config = (new AsyncHttpClientConfig.Builder()) - .setAllowPoolingConnection(true) - .setAllowSslConnectionPool(true) + .setAllowPoolingConnections(true) + .setAllowPoolingSslConnections(true) .addRequestFilter(new ThrottleRequestFilter(threadLimit)) - .setMaximumConnectionsPerHost(threadLimit) - .setRequestTimeoutInMs(timeout * 1000) + .setMaxConnectionsPerHost(threadLimit) + .setRequestTimeout(timeout * 1000) .setIOThreadMultiplier(threadLimit) .build(); this.client = new AsyncHttpClient(new NettyAsyncHttpProvider(config), config);
