Package de.hybris.platform.solrfacetsearch.solr.impl

Class DefaultSolrClientPool

java.lang.Object

de.hybris.platform.solrfacetsearch.solr.impl.DefaultSolrClientPool

All Implemented Interfaces:

SolrClientPool, org.springframework.beans.factory.InitializingBean

public class DefaultSolrClientPool
extends java.lang.Object
implements SolrClientPool, org.springframework.beans.factory.InitializingBean

Default implementation for SolrClientPool.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	DefaultSolrClientPool.SolrClientPoolTenantListener

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	CHECK_INTERVAL_DEFAULT_VALUE
protected static java.lang.String	CHECK_INTERVAL_PROPERTY
protected static java.lang.String	CHECK_THREAD_NAME_PREFIX
protected static java.lang.String	CREATE_METHOD_PARAM
protected static java.lang.String	INDEX_PARAM
protected static long	SCHEDULER_TERMINATION_TIMEOUT
protected static java.lang.String	SOLR_CLIENT_PARAM

Constructor Summary

Constructors

Constructor	Description
DefaultSolrClientPool()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected SolrClientsWrapper	check(java.lang.String solrServerConfigName, SolrClientsWrapper clientsWrapper)
protected void	checkAll()
protected CachedSolrClient	createSolrClient(SolrConfig solrConfig, SolrClientConfig solrClientConfig, java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod, java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)
protected TenantListener	createTenantListener()
protected void	destroySession()
protected SolrClientsWrapper	doGetOrCreate(SolrConfig solrConfig, SolrClientsWrapper clientsWrapper, SolrClientType clientType, java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod, java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)
ConfigurationService	getConfigurationService()
ModelService	getModelService()
CachedSolrClient	getOrCreate(Index index, SolrClientType clientType, java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod)	Returns a SolrClient from the pool or creates it if it does not exist.
CachedSolrClient	getOrCreate(Index index, SolrClientType clientType, java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod, java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)	Returns a SolrClient from the pool or creates it if it does not exist.
protected java.util.concurrent.ScheduledExecutorService	getScheduler()
SessionService	getSessionService()
protected java.util.concurrent.ConcurrentMap<java.lang.String,SolrClientsWrapper>	getSolrClients()
Converter<SolrServerConfigModel,SolrConfig>	getSolrServerConfigConverter()
SolrServerConfigDao	getSolrServerConfigDao()
protected java.lang.String	getTenantId()
TenantService	getTenantService()
protected void	initializeSession()
void	invalidateAll()	Invalidates the clients pool.
protected SolrServerConfigModel	loadSolrServerConfig(java.lang.String name)
protected CachedSolrClient	resolveSolrClient(SolrClientsWrapper clientsWrapper, SolrClientType solrClientType)
void	setConfigurationService(ConfigurationService configurationService)
void	setModelService(ModelService modelService)
void	setSessionService(SessionService sessionService)
void	setSolrServerConfigConverter(Converter<SolrServerConfigModel,SolrConfig> solrServerConfigConverter)
void	setSolrServerConfigDao(SolrServerConfigDao solrServerConfigDao)
void	setTenantService(TenantService tenantService)
protected void	startCleanUpThread()
protected void	stopCleanUpThread()

Methods inherited from class java.lang.Object

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

Field Detail

INDEX_PARAM

protected static final java.lang.String INDEX_PARAM

See Also:

Constant Field Values

SOLR_CLIENT_PARAM

protected static final java.lang.String SOLR_CLIENT_PARAM

See Also:

Constant Field Values

CREATE_METHOD_PARAM

protected static final java.lang.String CREATE_METHOD_PARAM

See Also:

Constant Field Values

CHECK_INTERVAL_PROPERTY

protected static final java.lang.String CHECK_INTERVAL_PROPERTY

See Also:

Constant Field Values

CHECK_INTERVAL_DEFAULT_VALUE

protected static final long CHECK_INTERVAL_DEFAULT_VALUE

See Also:

Constant Field Values

CHECK_THREAD_NAME_PREFIX

protected static final java.lang.String CHECK_THREAD_NAME_PREFIX

See Also:

Constant Field Values

SCHEDULER_TERMINATION_TIMEOUT

protected static final long SCHEDULER_TERMINATION_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

DefaultSolrClientPool

public DefaultSolrClientPool()

Method Detail

getTenantId

protected java.lang.String getTenantId()

getScheduler

protected java.util.concurrent.ScheduledExecutorService getScheduler()

getSolrClients

protected java.util.concurrent.ConcurrentMap<java.lang.String,SolrClientsWrapper> getSolrClients()

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

getOrCreate

public CachedSolrClient getOrCreate(Index index,
                                    SolrClientType clientType,
                                    java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod)
                             throws SolrServiceException

Description copied from interface: SolrClientPool

Returns a SolrClient from the pool or creates it if it does not exist.

Specified by:

getOrCreate in interface SolrClientPool

Parameters:

index - - Index

clientType - - SolrClientType

createMethod - - method used to create a new instance of SolrClient

Returns:

SolrClient

Throws:

SolrServiceException - if an error occurs

getOrCreate

public CachedSolrClient getOrCreate(Index index,
                                    SolrClientType clientType,
                                    java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod,
                                    java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)
                             throws SolrServiceException

Description copied from interface: SolrClientPool

Returns a SolrClient from the pool or creates it if it does not exist.

Specified by:

getOrCreate in interface SolrClientPool

Parameters:

index - - Index

clientType - - SolrClientType

createMethod - - method used to create a new instance of SolrClient

closeMethod - - method used to release resources associated with the created instance of SolrClient

Returns:

SolrClient

Throws:

SolrServiceException - if an error occurs

invalidateAll

public void invalidateAll()

Description copied from interface: SolrClientPool

Invalidates the clients pool.

Specified by:

invalidateAll in interface SolrClientPool

resolveSolrClient

protected CachedSolrClient resolveSolrClient(SolrClientsWrapper clientsWrapper,
                                             SolrClientType solrClientType)

doGetOrCreate

protected SolrClientsWrapper doGetOrCreate(SolrConfig solrConfig,
                                           SolrClientsWrapper clientsWrapper,
                                           SolrClientType clientType,
                                           java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod,
                                           java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)

createSolrClient

protected CachedSolrClient createSolrClient(SolrConfig solrConfig,
                                            SolrClientConfig solrClientConfig,
                                            java.util.function.Function<SolrConfig,org.apache.solr.client.solrj.SolrClient> createMethod,
                                            java.util.function.Consumer<org.apache.solr.client.solrj.SolrClient> closeMethod)

createTenantListener

protected TenantListener createTenantListener()

loadSolrServerConfig

protected SolrServerConfigModel loadSolrServerConfig(java.lang.String name)

startCleanUpThread

protected void startCleanUpThread()

stopCleanUpThread

protected void stopCleanUpThread()

initializeSession

protected void initializeSession()

checkAll

protected void checkAll()

check

protected SolrClientsWrapper check(java.lang.String solrServerConfigName,
                                   SolrClientsWrapper clientsWrapper)

destroySession

protected void destroySession()

getModelService

public ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getConfigurationService

public ConfigurationService getConfigurationService()

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getTenantService

public TenantService getTenantService()

setTenantService

public void setTenantService(TenantService tenantService)

getSessionService

public SessionService getSessionService()

setSessionService

public void setSessionService(SessionService sessionService)

getSolrServerConfigDao

public SolrServerConfigDao getSolrServerConfigDao()

setSolrServerConfigDao

public void setSolrServerConfigDao(SolrServerConfigDao solrServerConfigDao)

getSolrServerConfigConverter

public Converter<SolrServerConfigModel,SolrConfig> getSolrServerConfigConverter()

setSolrServerConfigConverter

public void setSolrServerConfigConverter(Converter<SolrServerConfigModel,SolrConfig> solrServerConfigConverter)