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 <[email protected]> Authored: Tue Jun 9 17:44:49 2015 -0400 Committer: Chathuri Wimalasena <[email protected]> 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);
