airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chath...@apache.org
Subject [1/2] git commit: adding an exception
Date Thu, 25 Sep 2014 13:14:22 GMT
Repository: airavata
Updated Branches:
  refs/heads/messaging_framework 88d8638f2 -> 7ed2e3479


adding an exception


Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/aba775e7
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/aba775e7
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/aba775e7

Branch: refs/heads/messaging_framework
Commit: aba775e74423441740812c8e5b926b20a371122b
Parents: 88d8638
Author: Chathuri Wimalasena <kamalasini@gmail.com>
Authored: Thu Sep 25 09:13:18 2014 -0400
Committer: Chathuri Wimalasena <kamalasini@gmail.com>
Committed: Thu Sep 25 09:13:18 2014 -0400

----------------------------------------------------------------------
 .../api/server/listener/AiravataExperimentStatusUpdator.java      | 3 ++-
 .../airavata/gfac/core/monitor/AiravataJobStatusUpdator.java      | 3 ++-
 .../airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java     | 3 ++-
 .../gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java      | 3 ++-
 4 files changed, 8 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/aba775e7/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/listener/AiravataExperimentStatusUpdator.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/listener/AiravataExperimentStatusUpdator.java
b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/listener/AiravataExperimentStatusUpdator.java
index 9c8bded..c692a8c 100644
--- a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/listener/AiravataExperimentStatusUpdator.java
+++ b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/listener/AiravataExperimentStatusUpdator.java
@@ -56,7 +56,7 @@ public class AiravataExperimentStatusUpdator implements AbstractActivityListener
     }
     
     @Subscribe
-    public void setupExperimentStatus(WorkflowNodeStatusChangeEvent nodeStatus) {
+    public void setupExperimentStatus(WorkflowNodeStatusChangeEvent nodeStatus) throws Exception{
 		try {
 			boolean updateExperimentStatus=true;
 	        ExperimentState state = ExperimentState.UNKNOWN;
@@ -101,6 +101,7 @@ public class AiravataExperimentStatusUpdator implements AbstractActivityListener
             publisher.publish(message);
 		} catch (Exception e) {
             logger.error("Error persisting data" + e.getLocalizedMessage(), e);
+            throw new Exception("Error persisting experiment status..", e);
 		}
     }
     

http://git-wip-us.apache.org/repos/asf/airavata/blob/aba775e7/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataJobStatusUpdator.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataJobStatusUpdator.java
b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataJobStatusUpdator.java
index 5f9e36f..4f1f861 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataJobStatusUpdator.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataJobStatusUpdator.java
@@ -58,7 +58,7 @@ public class AiravataJobStatusUpdator implements AbstractActivityListener
{
 
 
     @Subscribe
-    public void updateRegistry(JobStatusChangeEvent jobStatus) {
+    public void updateRegistry(JobStatusChangeEvent jobStatus) throws Exception{
         /* Here we need to parse the jobStatus message and update
                 the registry accordingly, for now we are just printing to standard Out
                  */
@@ -82,6 +82,7 @@ public class AiravataJobStatusUpdator implements AbstractActivityListener
{
                 publisher.publish(message);
             } catch (Exception e) {
                 logger.error("Error persisting data" + e.getLocalizedMessage(), e);
+                throw new Exception("Error persisting job status..", e);
             }
         }
     }

http://git-wip-us.apache.org/repos/asf/airavata/blob/aba775e7/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java
b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java
index dd91c61..4e9bf29 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataTaskStatusUpdator.java
@@ -65,7 +65,7 @@ public class AiravataTaskStatusUpdator implements AbstractActivityListener
{
 //    }
 
     @Subscribe
-    public void setupTaskStatus(JobStatusChangeEvent jobStatus){
+    public void setupTaskStatus(JobStatusChangeEvent jobStatus) throws Exception{
     	TaskState state=TaskState.UNKNOWN;
     	switch(jobStatus.getState()){
     	case ACTIVE:
@@ -109,6 +109,7 @@ public class AiravataTaskStatusUpdator implements AbstractActivityListener
{
 
         } catch (Exception e) {
             logger.error("Error persisting data" + e.getLocalizedMessage(), e);
+            throw new Exception("Error persisting task status..", e);
 		}
     }
     

http://git-wip-us.apache.org/repos/asf/airavata/blob/aba775e7/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java
b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java
index 5b9a5ed..f2ef855 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/monitor/AiravataWorkflowNodeStatusUpdator.java
@@ -56,7 +56,7 @@ public class AiravataWorkflowNodeStatusUpdator implements AbstractActivityListen
     }
 
     @Subscribe
-    public void setupWorkflowNodeStatus(TaskStatusChangeEvent taskStatus){
+    public void setupWorkflowNodeStatus(TaskStatusChangeEvent taskStatus) throws Exception{
     	WorkflowNodeState state=WorkflowNodeState.UNKNOWN;
     	switch(taskStatus.getState()){
     	case CANCELED:
@@ -93,6 +93,7 @@ public class AiravataWorkflowNodeStatusUpdator implements AbstractActivityListen
             publisher.publish(message);
 		} catch (Exception e) {
             logger.error("Error persisting data" + e.getLocalizedMessage(), e);
+            throw new Exception("Error persisting workflow node status..", e);
 		}
     }
 


Mime
View raw message