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/324be8fa Tree: http://git-wip-us.apache.org/repos/asf/polygene-java/tree/324be8fa Diff: http://git-wip-us.apache.org/repos/asf/polygene-java/diff/324be8fa Branch: refs/heads/serialization-3.0 Commit: 324be8faf7b333c604018420915a00751847f878 Parents: 82a0039 Author: Paul Merlin <[email protected]> Authored: Sun Mar 26 17:02:50 2017 +0200 Committer: Paul Merlin <[email protected]> Committed: Sun Mar 26 17:02:50 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/324be8fa/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(
