de.hybris.platform.solrfacetsearch.solr.impl

Class DefaultSolrClientPool

java.lang.Object

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

All Implemented Interfaces:

SolrClientPool

public class DefaultSolrClientPool
extends Object
implements SolrClientPool

Default implementation for SolrClientPool.

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	CHECK_INTERVAL_DEFAULT_VALUE
protected static String	CHECK_INTERVAL_PROPERTY
protected static String	CHECK_THREAD_NAME_PREFIX
protected static long	SCHEDULER_TERMINATION_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DefaultSolrClientPool()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected Long[]	buildTimestamps(SolrConfig solrConfig)
protected void	checkAll()
protected void	closeSolrClientsWrapper(String solrConfigName, SolrClientsWrapper clientsWrapper)
protected CachedSolrClient	createSolrClient(SolrClientsWrapper clientsWrapper, SolrClientType solrClientType, SolrConfig solrConfig, Function<SolrConfig,SolrClient> createFunction)
protected void	destroySession()
ConfigurationService	getConfigurationService()
SolrClient	getOrCreate(Index index, SolrClientType solrClientType, Function<SolrConfig,SolrClient> createFunction) Get SolrClient from the pool, or create it if it does not exist.
protected ScheduledExecutorService	getScheduler()
SessionService	getSessionService()
protected ConcurrentMap<String,SolrClientsWrapper>	getSolrClients()
Converter<SolrServerConfigModel,SolrConfig>	getSolrServerConfigConverter()
SolrServerConfigDao	getSolrServerConfigDao()
protected String	getTenantId()
TenantService	getTenantService()
protected void	initializeSession()
void	invalidateAll() Invalidates the clients pool.
protected SolrConfig	loadSolrConfig(String solrConfigName)
protected SolrClientsWrapper	refreshWrapper(SolrConfig solrConfig, SolrClientsWrapper clientsWrapper, SolrClientType solrClientType, Function<SolrConfig,SolrClient> createFunction)
protected CachedSolrClient	resolveSolrClient(SolrClientsWrapper clientsWrapper, SolrClientType solrClientType)
void	setConfigurationService(ConfigurationService configurationService)
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

CHECK_INTERVAL_PROPERTY

protected static final 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 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 String getTenantId()

getScheduler

protected ScheduledExecutorService getScheduler()

getSolrClients

protected ConcurrentMap<String,SolrClientsWrapper> getSolrClients()

afterPropertiesSet

public void afterPropertiesSet()

getOrCreate

public SolrClient getOrCreate(Index index,
                              SolrClientType solrClientType,
                              Function<SolrConfig,SolrClient> createFunction)
                       throws SolrServiceException

Description copied from interface: SolrClientPool

Get SolrClient from the pool, or create it if it does not exist.

Specified by:

getOrCreate in interface SolrClientPool

Parameters:

index - - Index

solrClientType - - SolrClientType

createFunction - - Method to be used to create 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

checkAll

protected void checkAll()

refreshWrapper

protected SolrClientsWrapper refreshWrapper(SolrConfig solrConfig,
                                            SolrClientsWrapper clientsWrapper,
                                            SolrClientType solrClientType,
                                            Function<SolrConfig,SolrClient> createFunction)

resolveSolrClient

protected CachedSolrClient resolveSolrClient(SolrClientsWrapper clientsWrapper,
                                             SolrClientType solrClientType)

createSolrClient

protected CachedSolrClient createSolrClient(SolrClientsWrapper clientsWrapper,
                                            SolrClientType solrClientType,
                                            SolrConfig solrConfig,
                                            Function<SolrConfig,SolrClient> createFunction)

closeSolrClientsWrapper

protected void closeSolrClientsWrapper(String solrConfigName,
                                       SolrClientsWrapper clientsWrapper)

loadSolrConfig

protected SolrConfig loadSolrConfig(String solrConfigName)

buildTimestamps

protected Long[] buildTimestamps(SolrConfig solrConfig)

startCleanUpThread

protected void startCleanUpThread()

stopCleanUpThread

protected void stopCleanUpThread()

initializeSession

protected void initializeSession()

destroySession

protected void destroySession()

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)