You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ma...@apache.org on 2017/04/28 15:23:06 UTC
[25/50] [abbrv] airavata git commit: AIRAVATA-2352 Log error when
RabbitMQ client connection is shut down
AIRAVATA-2352 Log error when RabbitMQ client connection is shut down
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/eadbdba5
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/eadbdba5
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/eadbdba5
Branch: refs/heads/develop
Commit: eadbdba5be540557efd67645d109eded756054d0
Parents: 64fb9df
Author: Marcus Christie <ma...@apache.org>
Authored: Fri Apr 21 12:10:42 2017 -0400
Committer: Marcus Christie <ma...@apache.org>
Committed: Fri Apr 21 12:10:42 2017 -0400
----------------------------------------------------------------------
.../org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/eadbdba5/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java
----------------------------------------------------------------------
diff --git a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java
index 3eb4d33..4a4413b 100644
--- a/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java
+++ b/modules/messaging/core/src/main/java/org/apache/airavata/messaging/core/impl/RabbitMQSubscriber.java
@@ -149,6 +149,7 @@ public class RabbitMQSubscriber implements Subscriber {
private void addShutdownListener() {
connection.addShutdownListener(new ShutdownListener() {
public void shutdownCompleted(ShutdownSignalException cause) {
+ log.error("RabbitMQ connection " + connection + " for " + properties.getExchangeName() + " has been shut down", cause);
}
});
}