airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject git commit: adding more clear logs during startup and failures
Date Wed, 17 Sep 2014 15:58:25 GMT
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 <lahiru@apache.org>
Authored: Wed Sep 17 11:58:21 2014 -0400
Committer: lahiru <lahiru@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);
                     }
                 }
 


Mime
View raw message