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/master Commit: aba775e74423441740812c8e5b926b20a371122b Parents: 88d8638 Author: Chathuri Wimalasena <[email protected]> Authored: Thu Sep 25 09:13:18 2014 -0400 Committer: Chathuri Wimalasena <[email protected]> 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); } }
