org.ametys.cms.search.solr

Class DefaultSolrClientProvider

java.lang.Object

org.ametys.runtime.plugin.component.AbstractLogEnabled

org.ametys.cms.search.solr.DefaultSolrClientProvider

All Implemented Interfaces:

SolrClientProvider, LogEnabled, Disposable, Initializable, Component, Serviceable

public class DefaultSolrClientProvider
extends AbstractLogEnabled
implements SolrClientProvider, Component, Serviceable, Initializable, Disposable

Component acting as a single entry point to get access to Solr clients.

Field Summary

Fields

Modifier and Type	Field and Description
private static String	__SOLR_CORE_PREFIX_CONFIG
private static String	__SOLR_URL_CONFIG
protected String	_solrCorePrefix The solr core prefix.
protected Map<String,SolrClient>	_solrDefaultUpdateClients The Solr "default" update clients, per workspace
protected Map<String,SolrClient>	_solrNoAutoCommitUpdateClients The Solr "no auto commit" update clients, per workspace
protected SolrClient	_solrReadClient The Solr read client.
protected WorkspaceSelector	_workspaceSelector The workspace selector.

Fields inherited from interface org.ametys.cms.search.solr.SolrClientProvider

ROLE

Constructor Summary

Constructors

Constructor and Description
DefaultSolrClientProvider()

Method Summary

Modifier and Type	Method and Description
private SolrClient	_createDefaultUpdateClient(String url, String workspaceName)
private SolrClient	_createNoAutoCommitUpdateClient(String url, String workspaceName)
private String	_nonNullWorkspaceName(String workspaceName)
void	dispose()
String	getCollectionName() Get the name of the collection to use.
String	getCollectionName(String workspaceName) Get the collection to use.
SolrClient	getReadClient() Get the "read" mode solr client.
SolrClient	getUpdateClient(String workspaceName, boolean autoCommit) Get a Solr client suited to update.
void	initialize()
void	service(ServiceManager serviceManager)

Methods inherited from class org.ametys.runtime.plugin.component.AbstractLogEnabled

getLogger, setLogger

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.ametys.cms.search.solr.SolrClientProvider

getUpdateClient

Field Detail

__SOLR_URL_CONFIG

private static final String __SOLR_URL_CONFIG

See Also:

Constant Field Values

__SOLR_CORE_PREFIX_CONFIG

private static final String __SOLR_CORE_PREFIX_CONFIG

See Also:

Constant Field Values

_workspaceSelector

protected WorkspaceSelector _workspaceSelector

The workspace selector.

_solrReadClient

protected SolrClient _solrReadClient

The Solr read client.

_solrDefaultUpdateClients

protected Map<String,SolrClient> _solrDefaultUpdateClients

The Solr "default" update clients, per workspace

_solrNoAutoCommitUpdateClients

protected Map<String,SolrClient> _solrNoAutoCommitUpdateClients

The Solr "no auto commit" update clients, per workspace

_solrCorePrefix

protected String _solrCorePrefix

The solr core prefix.

Constructor Detail

DefaultSolrClientProvider

public DefaultSolrClientProvider()

Method Detail

service

public void service(ServiceManager serviceManager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

initialize

public void initialize()
                throws Exception

Specified by:

initialize in interface Initializable

Throws:

Exception

_createDefaultUpdateClient

private SolrClient _createDefaultUpdateClient(String url,
                                              String workspaceName)

_createNoAutoCommitUpdateClient

private SolrClient _createNoAutoCommitUpdateClient(String url,
                                                   String workspaceName)

dispose

public void dispose()

Specified by:

dispose in interface Disposable

getReadClient

public SolrClient getReadClient()

Description copied from interface: SolrClientProvider

Get the "read" mode solr client.

Specified by:

getReadClient in interface SolrClientProvider

Returns:

the "read" mode solr client.

getUpdateClient

public SolrClient getUpdateClient(String workspaceName,
                                  boolean autoCommit)

Description copied from interface: SolrClientProvider

Get a Solr client suited to update.
You must call this method with false value for argument `autocommit` so as to get a client that will not trigger any autocommit on Solr side.
Otherwise, calling this method with true value for argument `autocommit` is equivalent to calling SolrClientProvider.getUpdateClient(String)

Specified by:

getUpdateClient in interface SolrClientProvider

Parameters:

workspaceName - The name of the workspace

autoCommit - false so as to get a client that will not trigger any autocommit on Solr side.

Returns:

a Solr client suited to update.

getCollectionName

public String getCollectionName()

Description copied from interface: SolrClientProvider

Get the name of the collection to use.

Specified by:

getCollectionName in interface SolrClientProvider

Returns:

The name of the collection to search in.

getCollectionName

public String getCollectionName(String workspaceName)

Description copied from interface: SolrClientProvider

Get the collection to use.

Specified by:

getCollectionName in interface SolrClientProvider

Parameters:

workspaceName - The workspace name.

Returns:

The name of the collection to search in.

_nonNullWorkspaceName

private String _nonNullWorkspaceName(String workspaceName)