You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2015/05/16 08:20:07 UTC
airavata git commit: Adding null check for message publisher before
trying to publishing
Repository: airavata
Updated Branches:
refs/heads/master d8054829b -> 8ae827d91
Adding null check for message publisher before trying to publishing
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/8ae827d9
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/8ae827d9
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/8ae827d9
Branch: refs/heads/master
Commit: 8ae827d91401d68c767114b809fd6a6aaa4135e6
Parents: d805482
Author: Supun Nakandala <su...@gmail.com>
Authored: Sat May 16 11:49:26 2015 +0530
Committer: Supun Nakandala <su...@gmail.com>
Committed: Sat May 16 11:49:26 2015 +0530
----------------------------------------------------------------------
.../airavata/api/server/handler/AiravataServerHandler.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/8ae827d9/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 60dc8ee..fff3810 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
@@ -1107,7 +1107,9 @@ public class AiravataServerHandler implements Airavata.Iface {
String messageId = AiravataUtils.getId("EXPERIMENT");
MessageContext messageContext = new MessageContext(event, MessageType.EXPERIMENT, messageId, gatewayId);
messageContext.setUpdatedTime(AiravataUtils.getCurrentTimestamp());
- publisher.publish(messageContext);
+ if(publisher!=null) {
+ publisher.publish(messageContext);
+ }
logger.infoId(experimentId, "Created new experiment with experiment name {}", experiment.getName());
return experimentId;
} catch (Exception e) {