Fix value type lookup in elastic search indexer POLYGENE-105
Project: http://git-wip-us.apache.org/repos/asf/polygene-java/repo Commit: http://git-wip-us.apache.org/repos/asf/polygene-java/commit/bd392976 Tree: http://git-wip-us.apache.org/repos/asf/polygene-java/tree/bd392976 Diff: http://git-wip-us.apache.org/repos/asf/polygene-java/diff/bd392976 Branch: refs/heads/develop Commit: bd39297644f46d1e047667d1eea554d1b5000c61 Parents: 8895965 Author: Paul Merlin <[email protected]> Authored: Sun Mar 26 17:02:50 2017 +0200 Committer: Paul Merlin <[email protected]> Committed: Sun Apr 2 19:16:24 2017 +0200 ---------------------------------------------------------------------- .../polygene/index/elasticsearch/ElasticSearchIndexer.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/polygene-java/blob/bd392976/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/ElasticSearchIndexer.java ---------------------------------------------------------------------- diff --git a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/ElasticSearchIndexer.java b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/ElasticSearchIndexer.java index ad023bd..344f9d7 100644 --- a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/ElasticSearchIndexer.java +++ b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/ElasticSearchIndexer.java @@ -234,7 +234,7 @@ public interface ElasticSearchIndexer extends StateChangeListener else { EntityReference reference = EntityReference.create( associated.identity() ); - EntityState assocState = uow.entityStateOf( module, reference ); + EntityState assocState = uow.entityStateOf( entityType.module(), reference ); builder.add( key, Json.createReader( new StringReader( toJSON( assocState, newStates, uow ) @@ -273,7 +273,7 @@ public interface ElasticSearchIndexer extends StateChangeListener else { EntityReference reference = EntityReference.create( associated.identity() ); - EntityState assocState = uow.entityStateOf( module, reference ); + EntityState assocState = uow.entityStateOf( entityType.module(), reference ); assBuilder.add( Json.createReader( new StringReader( toJSON( assocState, newStates, uow ) @@ -318,7 +318,7 @@ public interface ElasticSearchIndexer extends StateChangeListener else { EntityReference reference = EntityReference.create( identity ); - EntityState assocState = uow.entityStateOf( module, reference ); + EntityState assocState = uow.entityStateOf( entityType.module(), reference ); assBuilder.add( JavaxJson.toBuilder( Json.createReader( new StringReader(
