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/30 22:02:32 UTC
[1/2] git commit: fixing
src/main/java/org/apache/airavata/gfac/monitor/impl/push/amqp/SimpleJobFinishConsumer.java
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 <la...@apache.org>
Authored: Tue Sep 30 16:02:06 2014 -0400
Committer: lahiru <la...@apache.org>
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);
}
[2/2] git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/airavata
Posted by la...@apache.org.
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/airavata
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/55285038
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/55285038
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/55285038
Branch: refs/heads/master
Commit: 55285038f5a9945ebb4b709b19927f3319579549
Parents: ffe8b9f 4917ce2
Author: lahiru <la...@apache.org>
Authored: Tue Sep 30 16:02:23 2014 -0400
Committer: lahiru <la...@apache.org>
Committed: Tue Sep 30 16:02:23 2014 -0400
----------------------------------------------------------------------
.../handler/GSISSHDirectorySetupHandler.java | 7 ---
.../gfac/gsissh/handler/GSISSHInputHandler.java | 9 +--
.../gsissh/handler/GSISSHOutputHandler.java | 11 +---
.../gsissh/provider/impl/GSISSHProvider.java | 10 +--
.../ssh/handler/AdvancedSCPInputHandler.java | 64 +++++++++++++-------
.../ssh/handler/AdvancedSCPOutputHandler.java | 34 ++++++++---
.../ssh/handler/SSHDirectorySetupHandler.java | 10 +--
.../gfac/ssh/handler/SSHInputHandler.java | 7 ---
.../gfac/ssh/handler/SSHOutputHandler.java | 8 ---
.../gfac/ssh/provider/impl/SSHProvider.java | 7 ---
10 files changed, 71 insertions(+), 96 deletions(-)
----------------------------------------------------------------------