Repository: airavata Updated Branches: refs/heads/develop 5f59387a8 -> 3418fda51
credential store client initialization retry attempts Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/3418fda5 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/3418fda5 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/3418fda5 Branch: refs/heads/develop Commit: 3418fda517036442769ec14385d0dd4e79e273cd Parents: 5f59387 Author: scnakandala <[email protected]> Authored: Mon May 2 13:40:04 2016 -0400 Committer: scnakandala <[email protected]> Committed: Mon May 2 13:40:04 2016 -0400 ---------------------------------------------------------------------- .../store/client/CredentialStoreClientFactory.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/3418fda5/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java ---------------------------------------------------------------------- diff --git a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java b/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java index 1e2fb76..7f49c10 100644 --- a/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java +++ b/modules/credential-store/credential-store-stubs/src/main/java/org/apache/airavata/credential/store/client/CredentialStoreClientFactory.java @@ -35,6 +35,14 @@ public class CredentialStoreClientFactory { try { TTransport transport = new TSocket(serverHost, serverPort); transport.open(); + int maxWaitTime = 4; + while(!transport.isOpen() && maxWaitTime > 0){ + try { + Thread.sleep(3000); + } catch (InterruptedException e) {} + maxWaitTime--; + transport.open(); + } TProtocol protocol = new TBinaryProtocol(transport); return new CredentialStoreService.Client(protocol); } catch (TTransportException e) {
