airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject [1/2] airavata git commit: adding extra logs to do more testing
Date Wed, 01 Apr 2015 14:25:21 GMT
Repository: airavata
Updated Branches:
  refs/heads/master 26cf7edd4 -> ac9dc30f5


adding extra logs to do more testing


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

Branch: refs/heads/master
Commit: 9a0024a574029bb10fbcf0146c783e772aa3ebbb
Parents: d892369
Author: Lahiru Gunathilake <glahiru@gmail.com>
Authored: Wed Apr 1 10:25:02 2015 -0400
Committer: Lahiru Gunathilake <glahiru@gmail.com>
Committed: Wed Apr 1 10:25:02 2015 -0400

----------------------------------------------------------------------
 .../airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/9a0024a5/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java
----------------------------------------------------------------------
diff --git a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java
b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java
index 0f95fbf..3d8a377 100644
--- a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java
+++ b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchPublisher.java
@@ -72,6 +72,7 @@ public class RabbitMQTaskLaunchPublisher implements Publisher{
             }
             byte[] messageBody = ThriftUtils.serializeThriftObject(message);
             rabbitMQProducer.sendToWorkerQueue(messageBody, routingKey);
+            log.info("Successfully published to launch queue ...");
         } catch (TException e) {
             String msg = "Error while deserializing the object";
             log.error(msg, e);


Mime
View raw message