UNOMI-101 : Fix null profile service in recurrent import routes

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

Branch: refs/heads/master
Commit: 2d9a95a53cd2c4f59245d60e6ab2eee612c4170f
Parents: d37b0be
Author: Abdelkader Midani <amid...@apache.org>
Authored: Thu Aug 10 01:22:16 2017 +0200
Committer: Abdelkader Midani <amid...@apache.org>
Committed: Thu Aug 10 01:22:16 2017 +0200

----------------------------------------------------------------------
 .../org/apache/unomi/router/core/context/RouterCamelContext.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/2d9a95a5/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/RouterCamelContext.java
----------------------------------------------------------------------
diff --git 
a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/RouterCamelContext.java
 
b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/RouterCamelContext.java
index 4596af7..302b77d 100644
--- 
a/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/RouterCamelContext.java
+++ 
b/extensions/router/router-core/src/main/java/org/apache/unomi/router/core/context/RouterCamelContext.java
@@ -191,6 +191,7 @@ public class RouterCamelContext implements 
SynchronousBundleListener {
             ProfileImportFromSourceRouteBuilder builder = new 
ProfileImportFromSourceRouteBuilder(kafkaProps, configType);
             
builder.setImportConfigurationList(Arrays.asList(importConfiguration));
             builder.setImportConfigurationService(importConfigurationService);
+            builder.setProfileService(profileService);
             builder.setAllowedEndpoints(allowedEndpoints);
             builder.setJacksonDataFormat(jacksonDataFormat);
             builder.setContext(camelContext);

Reply via email to