Repository: airavata Updated Branches: refs/heads/develop 3418fda51 -> 0c9e4be02
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/0c9e4be0 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/0c9e4be0 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/0c9e4be0 Branch: refs/heads/develop Commit: 0c9e4be024b7fe587f8b31a0c4399a2f65a82b15 Parents: 3418fda Author: scnakandala <[email protected]> Authored: Mon May 2 13:51:22 2016 -0400 Committer: scnakandala <[email protected]> Committed: Mon May 2 13:51:22 2016 -0400 ---------------------------------------------------------------------- .../store/client/CredentialStoreClientFactory.java | 8 -------- 1 file changed, 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/0c9e4be0/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 7f49c10..1e2fb76 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,14 +35,6 @@ 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) {
