You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2014/09/17 17:58:25 UTC
git commit: adding more clear logs during startup and failures
Repository: airavata
Updated Branches:
refs/heads/master 17e8fd3b3 -> d7bb14051
adding more clear logs during startup and failures
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/d7bb1405
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/d7bb1405
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/d7bb1405
Branch: refs/heads/master
Commit: d7bb140510ce61404ada0be28b50099573bd0d64
Parents: 17e8fd3
Author: lahiru <la...@apache.org>
Authored: Wed Sep 17 11:58:21 2014 -0400
Committer: lahiru <la...@apache.org>
Committed: Wed Sep 17 11:58:21 2014 -0400
----------------------------------------------------------------------
.../gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/d7bb1405/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java
index 407d208..2a3f360 100644
--- a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java
+++ b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java
@@ -46,11 +46,16 @@ public class SimpleJobFinishConsumer {
ConnectionFactory connFactory = new ConnectionFactory();
connFactory.setUri(uri);
Connection conn = connFactory.newConnection();
+ logger.info("--------Created the connection to Rabbitmq server successfully-------");
final Channel ch = conn.createChannel();
+ logger.info("--------Created the channel with Rabbitmq server successfully-------");
+
ch.queueDeclare(queueName, false, false, false, null);
+ logger.info("--------Declare the queue " + queueName + "the channel with Rabbitmq server successfully-------");
+
final QueueingConsumer consumer = new QueueingConsumer(ch);
ch.basicConsume(queueName, consumer);
(new Thread() {
@@ -63,7 +68,7 @@ public class SimpleJobFinishConsumer {
ch.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
}
} catch (Exception ex) {
- logger.error("Cannot connect to a RabbitMQ Server: " , ex);
+ logger.error("--------Cannot connect to a RabbitMQ Server--------" , ex);
}
}