You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/04/03 17:24:47 UTC
[07/11] airavata git commit: adding extra logs to do more testing
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/emailMonitoring
Commit: 9a0024a574029bb10fbcf0146c783e772aa3ebbb
Parents: d892369
Author: Lahiru Gunathilake <gl...@gmail.com>
Authored: Wed Apr 1 10:25:02 2015 -0400
Committer: Lahiru Gunathilake <gl...@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);