You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2012/11/20 22:03:33 UTC
svn commit: r1411861 - in
/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client:
api/ impl/ tools/
Author: chathuri
Date: Tue Nov 20 21:03:32 2012
New Revision: 1411861
URL: http://svn.apache.org/viewvc?rev=1411861&view=rev
Log:
updating airavata client
Added:
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java
- copied, changed from r1411749, airavata/trunk/modules/registry/registry-api/src/main/java/org/apache/airavata/registry/api/AbstractRegistryUpdaterThread.java
Modified:
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataManager.java
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ApplicationManager.java
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ProvenanceManager.java
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/AiravataManagerImpl.java
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ApplicationManagerImpl.java
airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataManager.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataManager.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataManager.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/AiravataManager.java Tue Nov 20 21:03:32 2012
@@ -21,7 +21,11 @@
package org.apache.airavata.client.api;
+import org.apache.airavata.registry.api.AiravataUser;
+import org.apache.airavata.registry.api.Gateway;
+
import java.net.URI;
+import java.util.Date;
import java.util.List;
/**
@@ -132,4 +136,44 @@ public interface AiravataManager {
* @throws AiravataAPIInvocationException
*/
public URI getRegistryURL(URI defaultURL) throws AiravataAPIInvocationException;
+
+ public void setConfiguration(String key, String value, Date expire) throws AiravataAPIInvocationException;
+
+ public void addConfiguration(String key, String value, Date expire) throws AiravataAPIInvocationException;
+
+ public void removeAllConfiguration(String key) throws AiravataAPIInvocationException;
+
+ public void removeConfiguration(String key, String value) throws AiravataAPIInvocationException;
+
+ public void addGFacURI(URI uri) throws AiravataAPIInvocationException;
+
+ public void addWorkflowInterpreterURI(URI uri) throws AiravataAPIInvocationException;
+
+ public void setEventingURI(URI uri) throws AiravataAPIInvocationException;
+
+ public void setMessageBoxURI(URI uri) throws AiravataAPIInvocationException;
+
+ public void addGFacURI(URI uri, Date expire) throws AiravataAPIInvocationException;
+
+ public void addWorkflowInterpreterURI(URI uri, Date expire) throws AiravataAPIInvocationException;
+
+ public void setEventingURI(URI uri, Date expire) throws AiravataAPIInvocationException;
+
+ public void setMessageBoxURI(URI uri, Date expire) throws AiravataAPIInvocationException;
+
+ public void removeGFacURI(URI uri) throws AiravataAPIInvocationException ;
+
+ public void removeAllGFacURI() throws AiravataAPIInvocationException;
+
+ public void removeWorkflowInterpreterURI(URI uri) throws AiravataAPIInvocationException;
+
+ public void removeAllWorkflowInterpreterURI() throws AiravataAPIInvocationException;
+
+ public void unsetEventingURI() throws AiravataAPIInvocationException;
+
+ public void unsetMessageBoxURI() throws AiravataAPIInvocationException;
+
+ public Gateway getGateway () throws AiravataAPIInvocationException;
+
+ public AiravataUser getUser() throws AiravataAPIInvocationException;
}
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ApplicationManager.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ApplicationManager.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ApplicationManager.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ApplicationManager.java Tue Nov 20 21:03:32 2012
@@ -27,6 +27,7 @@ import java.util.Map;
import org.apache.airavata.commons.gfac.type.ApplicationDeploymentDescription;
import org.apache.airavata.commons.gfac.type.HostDescription;
import org.apache.airavata.commons.gfac.type.ServiceDescription;
+import org.apache.airavata.registry.api.exception.RegistryException;
public interface ApplicationManager {
//Service descriptors
@@ -182,4 +183,16 @@ public interface ApplicationManager {
*/
public boolean deployServiceOnHost(String serviceName, String hostName)throws AiravataAPIInvocationException;
+ public Map<String,ApplicationDeploymentDescription> getApplicationDescriptors (String serviceName) throws AiravataAPIInvocationException;
+
+ public boolean isHostDescriptorExists(String descriptorName) throws AiravataAPIInvocationException;
+
+ public void removeHostDescriptor(String hostName) throws AiravataAPIInvocationException;
+
+ public boolean isServiceDescriptorExists(String descriptorName) throws AiravataAPIInvocationException;
+
+ public void removeServiceDescriptor(String serviceName) throws AiravataAPIInvocationException;
+
+ public void removeApplicationDescriptor(String serviceName, String hostName, String applicationName) throws AiravataAPIInvocationException;
+
}
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ProvenanceManager.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ProvenanceManager.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ProvenanceManager.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/api/ProvenanceManager.java Tue Nov 20 21:03:32 2012
@@ -24,15 +24,7 @@ package org.apache.airavata.client.api;
import java.util.List;
import java.util.Map;
-import org.apache.airavata.registry.api.workflow.ExperimentData;
-import org.apache.airavata.registry.api.workflow.ExperimentMetadata;
-import org.apache.airavata.registry.api.workflow.ExperimentName;
-import org.apache.airavata.registry.api.workflow.ExperimentUser;
-import org.apache.airavata.registry.api.workflow.WorkflowInstance;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceData;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceNode;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceNodeStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import org.apache.airavata.registry.api.workflow.*;
import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
/**
@@ -341,4 +333,10 @@ public interface ProvenanceManager {
public void addWorkflowInstance(String experimentId, WorkflowInstance workflowInstance) throws AiravataAPIInvocationException;
//TODO setup node type for the node & gram data for the node
+
+ public List<WorkflowInstance> getExperimentWorkflowInstances(String experimentId) throws AiravataAPIInvocationException;
+
+ public void setWorkflowNodeType(WorkflowInstanceNode node, WorkflowNodeType type) throws AiravataAPIInvocationException;
+
+ public void setWorkflowInstanceTemplateName(String workflowInstanceId,String templateName) throws AiravataAPIInvocationException;
}
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/AiravataManagerImpl.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/AiravataManagerImpl.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/AiravataManagerImpl.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/AiravataManagerImpl.java Tue Nov 20 21:03:32 2012
@@ -24,11 +24,14 @@ package org.apache.airavata.client.impl;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
+import java.util.Date;
import java.util.List;
import org.apache.airavata.client.AiravataClient;
import org.apache.airavata.client.api.AiravataAPIInvocationException;
import org.apache.airavata.client.api.AiravataManager;
+import org.apache.airavata.registry.api.AiravataUser;
+import org.apache.airavata.registry.api.Gateway;
import org.apache.airavata.registry.api.exception.RegistryException;
public class AiravataManagerImpl implements AiravataManager {
@@ -184,4 +187,176 @@ public class AiravataManagerImpl impleme
return getRegistryURL();
}
+ @Override
+ public void setConfiguration(String key, String value, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().setConfiguration(key, value, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void addConfiguration(String key, String value, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().addConfiguration(key, value, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeAllConfiguration(String key) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeAllConfiguration(key);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeConfiguration(String key, String value) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeConfiguration(key, value);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void addGFacURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().addGFacURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void addWorkflowInterpreterURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().addWorkflowInterpreterURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setEventingURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().setEventingURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setMessageBoxURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().setMessageBoxURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void addGFacURI(URI uri, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().addGFacURI(uri, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void addWorkflowInterpreterURI(URI uri, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().addWorkflowInterpreterURI(uri, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setEventingURI(URI uri, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().setEventingURI(uri, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setMessageBoxURI(URI uri, Date expire) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().setMessageBoxURI(uri, expire);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeGFacURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeGFacURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeAllGFacURI() throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeAllGFacURI();
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeWorkflowInterpreterURI(URI uri) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeWorkflowInterpreterURI(uri);
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeAllWorkflowInterpreterURI() throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().removeAllWorkflowInterpreterURI();
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void unsetEventingURI() throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().unsetEventingURI();
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void unsetMessageBoxURI() throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().unsetMessageBoxURI();
+ }catch (Exception e){
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public Gateway getGateway() throws AiravataAPIInvocationException {
+ return getClient().getRegistryClient().getGateway();
+ }
+
+ @Override
+ public AiravataUser getUser() throws AiravataAPIInvocationException {
+ return getClient().getRegistryClient().getUser();
+ }
+
}
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ApplicationManagerImpl.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ApplicationManagerImpl.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ApplicationManagerImpl.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ApplicationManagerImpl.java Tue Nov 20 21:03:32 2012
@@ -34,6 +34,7 @@ import org.apache.airavata.commons.gfac.
import org.apache.airavata.commons.gfac.type.HostDescription;
import org.apache.airavata.commons.gfac.type.ServiceDescription;
import org.apache.airavata.registry.api.exception.UnimplementedRegistryOperationException;
+import org.apache.airavata.registry.api.exception.gateway.MalformedDescriptorException;
public class ApplicationManagerImpl implements ApplicationManager {
private AiravataClient client;
@@ -234,7 +235,64 @@ public class ApplicationManagerImpl impl
throw new AiravataAPIInvocationException(new UnimplementedRegistryOperationException());
}
- public AiravataClient getClient() {
+ @Override
+ public Map<String, ApplicationDeploymentDescription> getApplicationDescriptors(String serviceName) throws AiravataAPIInvocationException {
+ try{
+ Map<String, ApplicationDeploymentDescription> applicationDescriptors = getClient().getRegistryClient().getApplicationDescriptors(serviceName);
+ return applicationDescriptors;
+ } catch (MalformedDescriptorException e) {
+ throw new AiravataAPIInvocationException(e);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public boolean isHostDescriptorExists(String descriptorName) throws AiravataAPIInvocationException {
+ try {
+ return getClient().getRegistryClient().isHostDescriptorExists(descriptorName);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeHostDescriptor(String hostName) throws AiravataAPIInvocationException {
+ try {
+ getClient().getRegistryClient().removeHostDescriptor(hostName);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public boolean isServiceDescriptorExists(String descriptorName) throws AiravataAPIInvocationException {
+ try {
+ return getClient().getRegistryClient().isServiceDescriptorExists(descriptorName);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeServiceDescriptor(String serviceName) throws AiravataAPIInvocationException {
+ try {
+ getClient().getRegistryClient().removeServiceDescriptor(serviceName);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void removeApplicationDescriptor(String serviceName, String hostName, String applicationName) throws AiravataAPIInvocationException {
+ try {
+ getClient().getRegistryClient().removeApplicationDescriptor(serviceName, hostName, applicationName);
+ } catch (RegistryException e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ public AiravataClient getClient() {
return client;
}
Modified: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java?rev=1411861&r1=1411860&r2=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/impl/ProvenanceManagerImpl.java Tue Nov 20 21:03:32 2012
@@ -30,17 +30,8 @@ import org.apache.airavata.client.api.Ai
import org.apache.airavata.client.api.ProvenanceManager;
import org.apache.airavata.registry.api.exception.RegistryException;
import org.apache.airavata.registry.api.AiravataExperiment;
-import org.apache.airavata.registry.api.workflow.ExperimentData;
-import org.apache.airavata.registry.api.workflow.ExperimentMetadata;
-import org.apache.airavata.registry.api.workflow.ExperimentName;
-import org.apache.airavata.registry.api.workflow.ExperimentUser;
-import org.apache.airavata.registry.api.workflow.WorkflowInstance;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceData;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceNode;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceNodeStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus;
+import org.apache.airavata.registry.api.workflow.*;
import org.apache.airavata.registry.api.workflow.WorkflowInstanceStatus.ExecutionStatus;
-import org.apache.airavata.registry.api.workflow.WorkflowNodeIOData;
public class ProvenanceManagerImpl implements ProvenanceManager {
private AiravataClient client;
@@ -407,7 +398,34 @@ public class ProvenanceManagerImpl imple
}
- @Override
+ @Override
+ public List<WorkflowInstance> getExperimentWorkflowInstances(String experimentId) throws AiravataAPIInvocationException {
+ try{
+ return getClient().getRegistryClient().getProvenanceResourceClient().getExperimentWorkflowInstances(experimentId);
+ }catch (Exception e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setWorkflowNodeType(WorkflowInstanceNode node, WorkflowNodeType type) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().getProvenanceResourceClient().updateWorkflowNodeType(node, type);
+ }catch (Exception e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
+ public void setWorkflowInstanceTemplateName(String workflowInstanceId, String templateName) throws AiravataAPIInvocationException {
+ try{
+ getClient().getRegistryClient().getProvenanceResourceClient().setWorkflowInstanceTemplateName(workflowInstanceId, templateName);
+ }catch (Exception e) {
+ throw new AiravataAPIInvocationException(e);
+ }
+ }
+
+ @Override
public ExperimentData getExperimentMetaInformation(String experimentId)
throws AiravataAPIInvocationException {
try {
Copied: airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java (from r1411749, airavata/trunk/modules/registry/registry-api/src/main/java/org/apache/airavata/registry/api/AbstractRegistryUpdaterThread.java)
URL: http://svn.apache.org/viewvc/airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java?p2=airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java&p1=airavata/trunk/modules/registry/registry-api/src/main/java/org/apache/airavata/registry/api/AbstractRegistryUpdaterThread.java&r1=1411749&r2=1411861&rev=1411861&view=diff
==============================================================================
--- airavata/trunk/modules/registry/registry-api/src/main/java/org/apache/airavata/registry/api/AbstractRegistryUpdaterThread.java (original)
+++ airavata/trunk/modules/airavata-client/src/main/java/org/apache/airavata/client/tools/PeriodicExecutorThread.java Tue Nov 20 21:03:32 2012
@@ -19,30 +19,29 @@
*
*/
-package org.apache.airavata.registry.api;
+package org.apache.airavata.client.tools;
-import org.apache.axis2.context.ConfigurationContext;
+import org.apache.airavata.client.api.AiravataAPI;
+import org.apache.airavata.registry.api.AiravataRegistry2;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.URI;
+public abstract class PeriodicExecutorThread extends Thread {
-public abstract class AbstractRegistryUpdaterThread extends Thread {
-
- private AiravataRegistry2 airavataRegistry2;
+ private AiravataAPI airavataAPI;
public static final int URL_UPDATE_INTERVAL = 1000 * 60 * 60 * 3;
public static final int JCR_AVAIALABILITY_WAIT_INTERVAL = 1000 * 10;
- private static final Logger log = LoggerFactory.getLogger(AbstractRegistryUpdaterThread.class);
+ private static final Logger log = LoggerFactory.getLogger(PeriodicExecutorThread.class);
- public AbstractRegistryUpdaterThread(AiravataRegistry2 registry) {
- airavataRegistry2 = registry;
+ public PeriodicExecutorThread(AiravataAPI airavataAPI) {
+ this.airavataAPI = airavataAPI;
}
public void run() {
while (true) {
try {
- updateRegistry(airavataRegistry2);
+ updateRegistry(airavataAPI);
Thread.sleep(URL_UPDATE_INTERVAL);
} catch (InterruptedException e) {
break;
@@ -59,5 +58,5 @@ public abstract class AbstractRegistryUp
}
}
- protected abstract void updateRegistry(AiravataRegistry2 registry) throws Exception;
+ protected abstract void updateRegistry(AiravataAPI airavataAPI) throws Exception;
}