You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2015/06/09 23:44:55 UTC
airavata git commit: info message when connection closed
Repository: airavata
Updated Branches:
refs/heads/airavata-0.15-release-branch bba8f752e -> 4487611cd
info message when connection closed
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/4487611c
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/4487611c
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/4487611c
Branch: refs/heads/airavata-0.15-release-branch
Commit: 4487611cda427a014ea6bac17c0a4b07ab2ff010
Parents: bba8f75
Author: Chathuri Wimalasena <ch...@apache.org>
Authored: Tue Jun 9 17:44:49 2015 -0400
Committer: Chathuri Wimalasena <ch...@apache.org>
Committed: Tue Jun 9 17:44:49 2015 -0400
----------------------------------------------------------------------
.../airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/4487611c/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java
----------------------------------------------------------------------
diff --git a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java
index 89a4a5d..4aeb804 100644
--- a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java
+++ b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQTaskLaunchConsumer.java
@@ -85,6 +85,7 @@ public class RabbitMQTaskLaunchConsumer {
connection = connectionFactory.newConnection();
connection.addShutdownListener(new ShutdownListener() {
public void shutdownCompleted(ShutdownSignalException cause) {
+ log.info("RabbitMQ connection shutting down");
}
});
log.info("connected to rabbitmq: " + connection + " for " + taskLaunchExchangeName);