Updated Branches: refs/heads/master 8b0d90ca1 -> 45815379c
Add configrable cloud controller client timeout Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/5e39a7ad Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/5e39a7ad Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/5e39a7ad Branch: refs/heads/master Commit: 5e39a7ad562ec989eaf22f6853113c0e8d2f6ae2 Parents: 676d64a Author: Lahiru Sandaruwan <[email protected]> Authored: Wed Dec 18 11:13:05 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Wed Dec 18 11:13:05 2013 +0530 ---------------------------------------------------------------------- .../autoscaler/client/cloud/controller/CloudControllerClient.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/5e39a7ad/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java index 904b38d..538e4b7 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java @@ -62,7 +62,10 @@ public class CloudControllerClient { int port = conf.getInt("autoscaler.cloudController.port", Constants.CLOUD_CONTROLLER_DEFAULT_PORT); String hostname = conf.getString("autoscaler.cloudController.hostname", "localhost"); String epr = "https://"; + hostname + ":" + port + "/" + Constants.CLOUD_CONTROLLER_SERVICE_SFX ; + int cloudControllerClientTimeout = conf.getInt("autoscaler.cloudController.clientTimeout", 180000); stub = new CloudControllerServiceStub(epr); + stub._getServiceClient().getOptions().setTimeOutInMilliSeconds(cloudControllerClientTimeout); + } catch (Exception e) { log.error("Stub init error", e); }
