Package org.ametys.cms.indexing.solr
Class SolrWorkspaceIndexer
- java.lang.Object
-
- org.ametys.runtime.plugin.component.AbstractLogEnabled
-
- org.ametys.cms.indexing.solr.SolrWorkspaceIndexer
-
- All Implemented Interfaces:
WorkspaceIndexer,LogEnabled,Component,Contextualizable,Serviceable
- Direct Known Subclasses:
SolrWebWorkspaceIndexer
public class SolrWorkspaceIndexer extends AbstractLogEnabled implements WorkspaceIndexer, Component, Serviceable, Contextualizable
Component indexing a workspace in a Solr server.
-
-
Field Summary
Fields Modifier and Type Field Description protected Context_contextThe component context.protected DocumentProviderExtensionPoint_docProviderEPAdditional documents provider extension point.protected Repository_repositoryThe repository.protected SolrClientProvider_solrClientProviderThe Solr client providerprotected SolrIndexer_solrIndexerThe solr indexer.protected WorkspaceSelector_workspaceSelectorThe workspace selector.-
Fields inherited from interface org.ametys.cms.indexing.WorkspaceIndexer
ROLE
-
-
Constructor Summary
Constructors Constructor Description SolrWorkspaceIndexer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcontextualize(Context context)protected voiddoIndex(String workspaceName)Index the given workspace.protected voidensureCoreExists(String coreName)Create the given core if it doesn't exist.protected voidensureCoresExists(String[] coreNames)Create the given cores if they do not exist.voidindex(String workspaceName)Index a workspace.protected voidindexAdditionalDocuments(String workspaceName, org.apache.solr.client.solrj.SolrClient solrClient)Index additional documents provided by the extensions.voidindexAllWorkspaces()Index all the workspaces.voidservice(ServiceManager manager)-
Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled
getLogger, setLogger
-
-
-
-
Field Detail
-
_repository
protected Repository _repository
The repository.
-
_solrIndexer
protected SolrIndexer _solrIndexer
The solr indexer.
-
_workspaceSelector
protected WorkspaceSelector _workspaceSelector
The workspace selector.
-
_docProviderEP
protected DocumentProviderExtensionPoint _docProviderEP
Additional documents provider extension point.
-
_solrClientProvider
protected SolrClientProvider _solrClientProvider
The Solr client provider
-
-
Constructor Detail
-
SolrWorkspaceIndexer
public SolrWorkspaceIndexer()
-
-
Method Detail
-
service
public void service(ServiceManager manager) throws ServiceException
- Specified by:
servicein interfaceServiceable- Throws:
ServiceException
-
contextualize
public void contextualize(Context context) throws ContextException
- Specified by:
contextualizein interfaceContextualizable- Throws:
ContextException
-
indexAllWorkspaces
public void indexAllWorkspaces() throws IndexingException
Description copied from interface:WorkspaceIndexerIndex all the workspaces.- Specified by:
indexAllWorkspacesin interfaceWorkspaceIndexer- Throws:
IndexingException- If an error occurs while indexing.
-
index
public void index(String workspaceName) throws IndexingException
Description copied from interface:WorkspaceIndexerIndex a workspace.- Specified by:
indexin interfaceWorkspaceIndexer- Parameters:
workspaceName- The workspace name.- Throws:
IndexingException- If an error occurs while indexing the workspace.
-
doIndex
protected void doIndex(String workspaceName) throws IndexingException
Index the given workspace.- Parameters:
workspaceName- The workspace name.- Throws:
IndexingException- If an error occurs indexing the workspace.
-
indexAdditionalDocuments
protected void indexAdditionalDocuments(String workspaceName, org.apache.solr.client.solrj.SolrClient solrClient) throws IndexingException
Index additional documents provided by the extensions.- Parameters:
workspaceName- The workspace name.solrClient- The solr client to use- Throws:
IndexingException- If an error occurs while indexing.
-
ensureCoresExists
protected void ensureCoresExists(String[] coreNames) throws IndexingException
Create the given cores if they do not exist.- Parameters:
coreNames- The core names.- Throws:
IndexingException- If an error occurs while checking if cores exist.
-
ensureCoreExists
protected void ensureCoreExists(String coreName) throws IndexingException
Create the given core if it doesn't exist.- Parameters:
coreName- The core name.- Throws:
IndexingException- If an error occurs while checking if core exists.
-
-