Repository: incubator-unomi
Updated Branches:
  refs/heads/feature-DMF-1343 9203d36f4 -> 993652a3f


DMF-1343 : Handle transforming an import config oneshot <--> recurrent


Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/993652a3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/993652a3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/993652a3

Branch: refs/heads/feature-DMF-1343
Commit: 993652a3f47c9cd4d6755f72226c66576d25e5d3
Parents: 9203d36
Author: Abdelkader Midani <amid...@apache.org>
Authored: Mon May 29 12:14:20 2017 +0200
Committer: Abdelkader Midani <amid...@apache.org>
Committed: Mon May 29 12:14:20 2017 +0200

----------------------------------------------------------------------
 .../core/context/ProfileImportCamelContext.java      | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/993652a3/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/ProfileImportCamelContext.java
----------------------------------------------------------------------
diff --git 
a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/ProfileImportCamelContext.java
 
b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/ProfileImportCamelContext.java
index 2f3eaad..df734d3 100644
--- 
a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/ProfileImportCamelContext.java
+++ 
b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/ProfileImportCamelContext.java
@@ -54,6 +54,8 @@ public class ProfileImportCamelContext implements 
SynchronousBundleListener {
     private String uploadDir;
     private Map<String, String> kafkaProps;
 
+    private final String IMPORT_CONFIG_TYPE_RECURRENT = "recurrent";
+
     private BundleContext bundleContext;
 
     public void setBundleContext(BundleContext bundleContext) {
@@ -109,11 +111,14 @@ public class ProfileImportCamelContext implements 
SynchronousBundleListener {
         if(route!=null && stopRoute(importConfiguration.getItemId())) {
             camelContext.removeRoute(importConfiguration.getItemId());
         }
-        ProfileImportSourceToKafkaRouteBuilder builder = new 
ProfileImportSourceToKafkaRouteBuilder(kafkaProps);
-        builder.setImportConfigurationList(Arrays.asList(importConfiguration));
-        builder.setJacksonDataFormat(jacksonDataFormat);
-        builder.setContext(camelContext);
-        camelContext.addRoutes(builder);
+        //Handle transforming an import config oneshot <--> recurrent
+        
if(IMPORT_CONFIG_TYPE_RECURRENT.equals(importConfiguration.getConfigType())){
+            ProfileImportSourceToKafkaRouteBuilder builder = new 
ProfileImportSourceToKafkaRouteBuilder(kafkaProps);
+            
builder.setImportConfigurationList(Arrays.asList(importConfiguration));
+            builder.setJacksonDataFormat(jacksonDataFormat);
+            builder.setContext(camelContext);
+            camelContext.addRoutes(builder);
+        }
     }
 
     public CamelContext getCamelContext() {

Reply via email to