POLYGENE-235 : Adding "query" and "indexing" tags to ElasticSearch indexing.
Project: http://git-wip-us.apache.org/repos/asf/polygene-java/repo Commit: http://git-wip-us.apache.org/repos/asf/polygene-java/commit/16485455 Tree: http://git-wip-us.apache.org/repos/asf/polygene-java/tree/16485455 Diff: http://git-wip-us.apache.org/repos/asf/polygene-java/diff/16485455 Branch: refs/heads/develop Commit: 1648545573ce67443993f215d0792cc34e70e7a4 Parents: 9a1ae98 Author: niclas <[email protected]> Authored: Sun Mar 5 13:36:11 2017 +0800 Committer: niclas <[email protected]> Committed: Sun Mar 5 13:36:11 2017 +0800 ---------------------------------------------------------------------- .../elasticsearch/assembly/ESClientIndexQueryAssembler.java | 1 + .../assembly/ESClusterIndexQueryAssembler.java | 9 +++++---- .../assembly/ESFilesystemIndexQueryAssembler.java | 9 +++++---- 3 files changed, 11 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/polygene-java/blob/16485455/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClientIndexQueryAssembler.java ---------------------------------------------------------------------- diff --git a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClientIndexQueryAssembler.java b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClientIndexQueryAssembler.java index eb73d62..10b1762 100644 --- a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClientIndexQueryAssembler.java +++ b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClientIndexQueryAssembler.java @@ -40,6 +40,7 @@ public class ESClientIndexQueryAssembler public void assemble( final ModuleAssembly module ) throws AssemblyException { module.services( ESClientIndexQueryService.class ) + .taggedWith( "elasticsearch", "query", "indexing" ) .identifiedBy( identity() ) .setMetaInfo( client ) .visibleIn( visibility() ) http://git-wip-us.apache.org/repos/asf/polygene-java/blob/16485455/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClusterIndexQueryAssembler.java ---------------------------------------------------------------------- diff --git a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClusterIndexQueryAssembler.java b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClusterIndexQueryAssembler.java index 018d199..269a877 100644 --- a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClusterIndexQueryAssembler.java +++ b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESClusterIndexQueryAssembler.java @@ -34,10 +34,11 @@ public class ESClusterIndexQueryAssembler public void assemble( ModuleAssembly module ) throws AssemblyException { - module.services( ESClusterIndexQueryService.class ). - identifiedBy( identity() ). - visibleIn( visibility() ). - instantiateOnStartup(); + module.services( ESClusterIndexQueryService.class ) + .taggedWith( "elasticsearch", "query", "indexing" ) + .identifiedBy( identity() ) + .visibleIn( visibility() ) + .instantiateOnStartup(); module.services( OrgJsonValueSerializationService.class ). taggedWith( ValueSerialization.Formats.JSON ); http://git-wip-us.apache.org/repos/asf/polygene-java/blob/16485455/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESFilesystemIndexQueryAssembler.java ---------------------------------------------------------------------- diff --git a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESFilesystemIndexQueryAssembler.java b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESFilesystemIndexQueryAssembler.java index acc5f4f..6b529ca 100644 --- a/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESFilesystemIndexQueryAssembler.java +++ b/extensions/indexing-elasticsearch/src/main/java/org/apache/polygene/index/elasticsearch/assembly/ESFilesystemIndexQueryAssembler.java @@ -34,10 +34,11 @@ public class ESFilesystemIndexQueryAssembler public void assemble( ModuleAssembly module ) throws AssemblyException { - module.services( ESFilesystemIndexQueryService.class ). - identifiedBy( identity() ). - visibleIn( visibility() ). - instantiateOnStartup(); + module.services( ESFilesystemIndexQueryService.class ) + .taggedWith( "elasticsearch", "query", "indexing" ) + .identifiedBy( identity() ) + .visibleIn( visibility() ) + .instantiateOnStartup(); module.services( OrgJsonValueSerializationService.class ). taggedWith( ValueSerialization.Formats.JSON );
