Repository: airavata Updated Branches: refs/heads/master 4917ce2a9 -> 55285038f
fixing src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/ffe8b9fd Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/ffe8b9fd Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/ffe8b9fd Branch: refs/heads/master Commit: ffe8b9fd1486a223000ccc175cd58b4799d76cb4 Parents: 9018dc8 Author: lahiru <[email protected]> Authored: Tue Sep 30 16:02:06 2014 -0400 Committer: lahiru <[email protected]> Committed: Tue Sep 30 16:02:06 2014 -0400 ---------------------------------------------------------------------- .../gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/ffe8b9fd/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 64f8d21..c4275f1 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 @@ -65,9 +65,10 @@ public class SimpleJobFinishConsumer { try { while (true) { QueueingConsumer.Delivery delivery = consumer.nextDelivery(); - logger.info("---------------- Job Finish message received:"+new String(delivery.getBody())+" --------------"); + String message = new String(delivery.getBody()); + logger.info("---------------- Job Finish message received:" + message + " --------------"); synchronized (completedJobsFromPush) { - completedJobsFromPush.add(new String(delivery.getBody())); + completedJobsFromPush.add(message); } ch.basicAck(delivery.getEnvelope().getDeliveryTag(), false); }
