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 <[email protected]> Authored: Wed Apr 1 10:25:02 2015 -0400 Committer: Lahiru Gunathilake <[email protected]> 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);
