You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2020/05/03 18:57:08 UTC
[airavata-mft] 09/15: adding FTP sender,
receiver and metadatadata collector to the core
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-mft.git
commit d3520b9d74d1d8b08373cdf71760c85cc778c43e
Author: Gopi Kiran <go...@gmail.com>
AuthorDate: Wed Apr 29 18:12:46 2020 -0400
adding FTP sender, receiver and metadatadata collector to the core
---
.../java/org/apache/airavata/mft/core/ConnectorResolver.java | 10 ++++++++++
.../apache/airavata/mft/core/MetadataCollectorResolver.java | 3 +++
2 files changed, 13 insertions(+)
diff --git a/core/src/main/java/org/apache/airavata/mft/core/ConnectorResolver.java b/core/src/main/java/org/apache/airavata/mft/core/ConnectorResolver.java
index 6c21932..469d19e 100644
--- a/core/src/main/java/org/apache/airavata/mft/core/ConnectorResolver.java
+++ b/core/src/main/java/org/apache/airavata/mft/core/ConnectorResolver.java
@@ -97,6 +97,16 @@ public final class ConnectorResolver {
break;
}
break;
+ case "FTP":
+ switch (direction) {
+ case "IN":
+ className = "org.apache.airavata.mft.transport.ftp.FTPReceiver";
+ break;
+ case "OUT":
+ className = "org.apache.airavata.mft.transport.ftp.FTPSender";
+ break;
+ }
+ break;
}
if (className != null) {
diff --git a/core/src/main/java/org/apache/airavata/mft/core/MetadataCollectorResolver.java b/core/src/main/java/org/apache/airavata/mft/core/MetadataCollectorResolver.java
index fefcd5a..c9da731 100644
--- a/core/src/main/java/org/apache/airavata/mft/core/MetadataCollectorResolver.java
+++ b/core/src/main/java/org/apache/airavata/mft/core/MetadataCollectorResolver.java
@@ -48,6 +48,9 @@ public final class MetadataCollectorResolver {
case "DROPBOX":
className = "org.apache.airavata.mft.transport.dropbox.DropboxMetadataCollector";
break;
+ case "FTP":
+ className = "org.apache.airavata.mft.transport.ftp.FTPMetadataCollector";
+ break;
}
if (className != null) {