[airavata] branch master updated: Bringing back publishing task status over message bus

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/master by this push:
     new a604566  Bringing back publishing task status over message bus
a604566 is described below

commit a6045664bb2d4260aea7f6919ed7b32b5116131a
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu May 2 16:33:56 2019 -0400

    Bringing back publishing task status over message bus
---
 .../main/java/org/apache/airavata/helix/impl/task/AiravataTask.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
index b3380c9..5041d63 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/AiravataTask.java
@@ -420,14 +420,14 @@ public abstract class AiravataTask extends AbstractTask {
             taskStatus.setState(ts);
             taskStatus.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp().getTime());
             getRegistryServiceClient().addTaskStatus(taskStatus, getTaskId());
-            /*TaskIdentifier identifier = new TaskIdentifier(getTaskId(),
+            TaskIdentifier identifier = new TaskIdentifier(getTaskId(),
                     getProcessId(), getExperimentId(), getGatewayId());
             TaskStatusChangeEvent taskStatusChangeEvent = new TaskStatusChangeEvent(ts,
                     identifier);
             MessageContext msgCtx = new MessageContext(taskStatusChangeEvent, MessageType.TASK, AiravataUtils.getId
                     (MessageType.TASK.name()), getGatewayId());
             msgCtx.setUpdatedTime(AiravataUtils.getCurrentTimestamp());
-            statusPublisher.publish(msgCtx);*/
+            statusPublisher.publish(msgCtx);
         } catch (Exception e) {
             logger.error("Failed to publish task status " + (ts != null ? ts.name(): "null") +" of task " + getTaskId());
         }