Package org.ametys.cms.search.solr

Class NoAutoCommitUpdateClient

java.lang.Object

org.apache.solr.client.solrj.SolrClient

org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient

org.ametys.cms.search.solr.AbstractAmetysConcurrentUpdateClient

org.ametys.cms.search.solr.NoAutoCommitUpdateClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class NoAutoCommitUpdateClient
extends AbstractAmetysConcurrentUpdateClient

Update SolrClient which uses the Solr `noAutoCommit` Update Request Processor chain, so as to not trigger the autoCommit mechanism.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient

org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient.Builder

Constructor Summary

Constructors

Constructor	Description
NoAutoCommitUpdateClient(String solrServerUrl, Optional<Integer> solrSocketTimeout, String collectionName, int queueSize, int threadCount, org.slf4j.Logger logger)	Constructor

Method Summary

Modifier and Type	Method	Description
org.apache.solr.common.util.NamedList<Object>	request(org.apache.solr.client.solrj.SolrRequest request, String collection)

Methods inherited from class org.ametys.cms.search.solr.AbstractAmetysConcurrentUpdateClient

add, add, add, add, add, add, add, add, add, add, addBean, addBean, addBean, addBean, addBeans, addBeans, addBeans, addBeans, addBeans, addBeans, commit, commit, commit, commit, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, deleteByQuery, deleteByQuery, handleError, onSuccess, optimize, optimize, optimize, optimize, optimize, optimize, rollback, rollback

Methods inherited from class org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient

blockUntilFinished, close, getQueryParams, setConnectionTimeout, setParser, setPollQueueTime, setQueryParams, setRequestWriter, setSoTimeout, shutdownNow

Methods inherited from class org.apache.solr.client.solrj.SolrClient

getBinder, getById, getById, getById, getById, getById, getById, getById, getById, ping, ping, query, query, query, query, queryAndStreamResponse, queryAndStreamResponse, queryAndStreamResponse, request

Methods inherited from class java.lang.Object

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

Constructor Detail

NoAutoCommitUpdateClient

public NoAutoCommitUpdateClient(String solrServerUrl,
                                Optional<Integer> solrSocketTimeout,
                                String collectionName,
                                int queueSize,
                                int threadCount,
                                org.slf4j.Logger logger)

Constructor

Parameters:

solrServerUrl - The Solr server URL

solrSocketTimeout - The Solr socket timeout (in millis)

collectionName - The name of the collection, on which operations will be allowed. Operations on other collections will be forbidden.

queueSize - The buffer size before the documents are sent to the server

threadCount - The number of background threads used to empty the queue

logger - internal logger

Method Detail

request

public org.apache.solr.common.util.NamedList<Object> request(org.apache.solr.client.solrj.SolrRequest request,
                                                             String collection)
                                                      throws org.apache.solr.client.solrj.SolrServerException,
                                                             IOException

Overrides:

request in class org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException