Repository: incubator-unomi Updated Branches: refs/heads/master 27b945978 -> 194c73ee2
UNOMI-16 : Fixed elasticsearch startup, register mapping in starting event Project: http://git-wip-us.apache.org/repos/asf/incubator-unomi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-unomi/commit/194c73ee Tree: http://git-wip-us.apache.org/repos/asf/incubator-unomi/tree/194c73ee Diff: http://git-wip-us.apache.org/repos/asf/incubator-unomi/diff/194c73ee Branch: refs/heads/master Commit: 194c73ee2cad0dee80c8658b9d65f493a772c8e8 Parents: 815ab75 Author: Thomas Draier <[email protected]> Authored: Fri Feb 5 11:22:07 2016 +0100 Committer: Thomas Draier <[email protected]> Committed: Fri Feb 5 11:32:20 2016 +0100 ---------------------------------------------------------------------- .../elasticsearch/ElasticSearchPersistenceServiceImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-unomi/blob/194c73ee/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java ---------------------------------------------------------------------- diff --git a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java index 042f5c1..a743237 100644 --- a/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java +++ b/persistence-elasticsearch/core/src/main/java/org/apache/unomi/persistence/elasticsearch/ElasticSearchPersistenceServiceImpl.java @@ -342,7 +342,7 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, @Override public void bundleChanged(BundleEvent event) { switch (event.getType()) { - case BundleEvent.STARTING: + case BundleEvent.STARTED: if (event.getBundle() != null && event.getBundle().getRegisteredServices() != null) { for (ServiceReference<?> reference : event.getBundle().getRegisteredServices()) { Object service = bundleContext.getService(reference); @@ -354,6 +354,8 @@ public class ElasticSearchPersistenceServiceImpl implements PersistenceService, } } } + break; + case BundleEvent.STARTING: loadPredefinedMappings(event.getBundle().getBundleContext(), true); break; case BundleEvent.STOPPING:
