Package org.ametys.cms.search.solr

Class DefaultUpdateClient

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.DefaultUpdateClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class DefaultUpdateClient
extends AbstractAmetysConcurrentUpdateClient

Default update SolrClient which uses the Solr default Update Request Processor chain

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
DefaultUpdateClient(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.client.solrj.response.UpdateResponse	commit()
org.apache.solr.client.solrj.response.UpdateResponse	commit(boolean waitFlush, boolean waitSearcher)
org.apache.solr.client.solrj.response.UpdateResponse	commit(boolean waitFlush, boolean waitSearcher, boolean softCommit)
org.apache.solr.client.solrj.response.UpdateResponse	commit(String collection)
org.apache.solr.client.solrj.response.UpdateResponse	commit(String collection, boolean waitFlush, boolean waitSearcher)
org.apache.solr.client.solrj.response.UpdateResponse	commit(String collection, boolean waitFlush, boolean waitSearcher, boolean softCommit)

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, 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, request, 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

DefaultUpdateClient

public DefaultUpdateClient(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

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit()
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit(boolean waitFlush,
                                                                   boolean waitSearcher)
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit(boolean waitFlush,
                                                                   boolean waitSearcher,
                                                                   boolean softCommit)
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit(String collection)
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit(String collection,
                                                                   boolean waitFlush,
                                                                   boolean waitSearcher)
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException

commit

public org.apache.solr.client.solrj.response.UpdateResponse commit(String collection,
                                                                   boolean waitFlush,
                                                                   boolean waitSearcher,
                                                                   boolean softCommit)
                                                            throws org.apache.solr.client.solrj.SolrServerException,
                                                                   IOException

Overrides:

commit in class AbstractAmetysConcurrentUpdateClient

Throws:

org.apache.solr.client.solrj.SolrServerException

IOException