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/05/29 10:14:23 UTC
incubator-unomi git commit: DMF-1343 : Handle transforming an import
config oneshot <--> recurrent
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 <am...@apache.org>
Authored: Mon May 29 12:14:20 2017 +0200
Committer: Abdelkader Midani <am...@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() {