You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@unomi.apache.org by am...@apache.org on 2017/06/06 15:36:44 UTC
[17/17] incubator-unomi git commit: DMF-1343 : Handle transforming an
import config oneshot <--> recurrent
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/8686a572
Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/8686a572
Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/8686a572
Branch: refs/heads/feature-DMF-1343
Commit: 8686a572fb69725264fe27be16a9e79405cfbb3d
Parents: 3c60204
Author: Abdelkader Midani <am...@apache.org>
Authored: Mon May 29 12:14:20 2017 +0200
Committer: Abdelkader Midani <am...@apache.org>
Committed: Tue Jun 6 17:35:46 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/8686a572/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() {