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 <[email protected]> Authored: Wed Sep 17 11:58:21 2014 -0400 Committer: lahiru <[email protected]> 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); } }
