Set update time for experiment launch and cancel events
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/3fcde529 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/3fcde529 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/3fcde529 Branch: refs/heads/lahiru/AIRAVATA-2057 Commit: 3fcde5295b75e58ff39f3442ed060d969443594c Parents: f4aeee5 Author: Shameera Rathnayaka <[email protected]> Authored: Mon Aug 15 13:12:34 2016 -0400 Committer: Shameera Rathnayaka <[email protected]> Committed: Mon Aug 15 13:12:34 2016 -0400 ---------------------------------------------------------------------- .../apache/airavata/api/server/handler/AiravataServerHandler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/3fcde529/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java index 5d8a8f9..8ce1c65 100644 --- a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java +++ b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java @@ -3651,12 +3651,14 @@ public class AiravataServerHandler implements Airavata.Iface { private void submitExperiment(String gatewayId,String experimentId) throws AiravataException { ExperimentSubmitEvent event = new ExperimentSubmitEvent(experimentId, gatewayId); MessageContext messageContext = new MessageContext(event, MessageType.EXPERIMENT, "LAUNCH.EXP-" + UUID.randomUUID().toString(), gatewayId); + messageContext.setUpdatedTime(AiravataUtils.getCurrentTimestamp()); experimentPublisher.publish(messageContext); } private void submitCancelExperiment(String gatewayId, String experimentId) throws AiravataException { ExperimentSubmitEvent event = new ExperimentSubmitEvent(experimentId, gatewayId); MessageContext messageContext = new MessageContext(event, MessageType.EXPERIMENT_CANCEL, "CANCEL.EXP-" + UUID.randomUUID().toString(), gatewayId); + messageContext.setUpdatedTime(AiravataUtils.getCurrentTimestamp()); experimentPublisher.publish(messageContext); }
