org.ametys.cms.search.solr

Class AmetysConcurrentUpdateSolrClient

java.lang.Object

org.apache.solr.client.solrj.SolrClient

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

org.ametys.cms.search.solr.AmetysConcurrentUpdateSolrClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

public class AmetysConcurrentUpdateSolrClient
extends ConcurrentUpdateSolrClient

Concurrent update solr client specific for Ametys.
Allow operations on only one collection (specified by the constructor), and forbid operations on all other collections. Delegate the processing to the ConcurrentUpdateSolrClient (superclass) if the collection is the one in use

See Also:

Serialized Form

Nested Class Summary

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

ConcurrentUpdateSolrClient.Builder

Field Summary

Fields

Modifier and Type	Field and Description
private String	_collectionName Name of the collection, on which operation are allowed
private Logger	_logger

Constructor Summary

Constructors

Constructor and Description
AmetysConcurrentUpdateSolrClient(String solrServerUrl, String collectionName, int queueSize, int threadCount, Logger logger) Constructor

Method Summary

Modifier and Type	Method and Description
private void	_checkCollectionInUse(String collection)
UpdateResponse	add(Collection<SolrInputDocument> docs)
UpdateResponse	add(Collection<SolrInputDocument> docs, int commitWithinMs)
UpdateResponse	add(Iterator<SolrInputDocument> docIterator)
UpdateResponse	add(SolrInputDocument doc)
UpdateResponse	add(SolrInputDocument doc, int commitWithinMs)
UpdateResponse	add(String collection, Collection<SolrInputDocument> docs)
UpdateResponse	add(String collection, Collection<SolrInputDocument> docs, int commitWithinMs)
UpdateResponse	add(String collection, Iterator<SolrInputDocument> docIterator)
UpdateResponse	add(String collection, SolrInputDocument doc)
UpdateResponse	add(String collection, SolrInputDocument doc, int commitWithinMs)
UpdateResponse	addBean(Object obj)
UpdateResponse	addBean(Object obj, int commitWithinMs)
UpdateResponse	addBean(String collection, Object obj)
UpdateResponse	addBean(String collection, Object obj, int commitWithinMs)
UpdateResponse	addBeans(Collection<?> beans)
UpdateResponse	addBeans(Collection<?> beans, int commitWithinMs)
UpdateResponse	addBeans(Iterator<?> beanIterator)
UpdateResponse	addBeans(String collection, Collection<?> beans)
UpdateResponse	addBeans(String collection, Collection<?> beans, int commitWithinMs)
UpdateResponse	addBeans(String collection, Iterator<?> beanIterator)
UpdateResponse	commit()
UpdateResponse	commit(boolean waitFlush, boolean waitSearcher)
UpdateResponse	commit(boolean waitFlush, boolean waitSearcher, boolean softCommit)
UpdateResponse	commit(String collection)
UpdateResponse	commit(String collection, boolean waitFlush, boolean waitSearcher)
UpdateResponse	commit(String collection, boolean waitFlush, boolean waitSearcher, boolean softCommit)
UpdateResponse	deleteById(List<String> ids)
UpdateResponse	deleteById(List<String> ids, int commitWithinMs)
UpdateResponse	deleteById(String id)
UpdateResponse	deleteById(String id, int commitWithinMs)
UpdateResponse	deleteById(String collection, List<String> ids)
UpdateResponse	deleteById(String collection, List<String> ids, int commitWithinMs)
UpdateResponse	deleteById(String collection, String id)
UpdateResponse	deleteById(String collection, String id, int commitWithinMs)
UpdateResponse	deleteByQuery(String query)
UpdateResponse	deleteByQuery(String query, int commitWithinMs)
UpdateResponse	deleteByQuery(String collection, String query)
UpdateResponse	deleteByQuery(String collection, String query, int commitWithinMs)
void	handleError(Throwable t)
void	onSuccess(org.apache.http.HttpResponse resp)
UpdateResponse	optimize()
UpdateResponse	optimize(boolean waitFlush, boolean waitSearcher)
UpdateResponse	optimize(boolean waitFlush, boolean waitSearcher, int maxSegments)
UpdateResponse	optimize(String collection)
UpdateResponse	optimize(String collection, boolean waitFlush, boolean waitSearcher)
UpdateResponse	optimize(String collection, boolean waitFlush, boolean waitSearcher, int maxSegments)
UpdateResponse	rollback()
UpdateResponse	rollback(String collection)

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

Methods inherited from class java.lang.Object

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

Field Detail

_collectionName

private String _collectionName

Name of the collection, on which operation are allowed

_logger

private Logger _logger

Constructor Detail

AmetysConcurrentUpdateSolrClient

public AmetysConcurrentUpdateSolrClient(String solrServerUrl,
                                        String collectionName,
                                        int queueSize,
                                        int threadCount,
                                        Logger logger)

Constructor

Parameters:

solrServerUrl - The Solr server URL

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

handleError

public void handleError(Throwable t)

Overrides:

handleError in class ConcurrentUpdateSolrClient

onSuccess

public void onSuccess(org.apache.http.HttpResponse resp)

Overrides:

onSuccess in class ConcurrentUpdateSolrClient

_checkCollectionInUse

private void _checkCollectionInUse(String collection)
                            throws SolrServerException

Throws:

SolrServerException

add

public UpdateResponse add(String collection,
                          Collection<SolrInputDocument> docs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(Collection<SolrInputDocument> docs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(String collection,
                          Collection<SolrInputDocument> docs,
                          int commitWithinMs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(Collection<SolrInputDocument> docs,
                          int commitWithinMs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(String collection,
                          SolrInputDocument doc)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(SolrInputDocument doc)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(String collection,
                          SolrInputDocument doc,
                          int commitWithinMs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(SolrInputDocument doc,
                          int commitWithinMs)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(String collection,
                          Iterator<SolrInputDocument> docIterator)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

add

public UpdateResponse add(Iterator<SolrInputDocument> docIterator)
                   throws SolrServerException,
                          IOException

Overrides:

add in class SolrClient

Throws:

SolrServerException

IOException

addBean

public UpdateResponse addBean(String collection,
                              Object obj)
                       throws IOException,
                              SolrServerException

Overrides:

addBean in class SolrClient

Throws:

IOException

SolrServerException

addBean

public UpdateResponse addBean(Object obj)
                       throws IOException,
                              SolrServerException

Overrides:

addBean in class SolrClient

Throws:

IOException

SolrServerException

addBean

public UpdateResponse addBean(String collection,
                              Object obj,
                              int commitWithinMs)
                       throws IOException,
                              SolrServerException

Overrides:

addBean in class SolrClient

Throws:

IOException

SolrServerException

addBean

public UpdateResponse addBean(Object obj,
                              int commitWithinMs)
                       throws IOException,
                              SolrServerException

Overrides:

addBean in class SolrClient

Throws:

IOException

SolrServerException

addBeans

public UpdateResponse addBeans(String collection,
                               Collection<?> beans)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

addBeans

public UpdateResponse addBeans(Collection<?> beans)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

addBeans

public UpdateResponse addBeans(String collection,
                               Collection<?> beans,
                               int commitWithinMs)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

addBeans

public UpdateResponse addBeans(Collection<?> beans,
                               int commitWithinMs)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

addBeans

public UpdateResponse addBeans(String collection,
                               Iterator<?> beanIterator)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

addBeans

public UpdateResponse addBeans(Iterator<?> beanIterator)
                        throws SolrServerException,
                               IOException

Overrides:

addBeans in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit(String collection)
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit()
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit(String collection,
                             boolean waitFlush,
                             boolean waitSearcher)
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit(boolean waitFlush,
                             boolean waitSearcher)
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit(String collection,
                             boolean waitFlush,
                             boolean waitSearcher,
                             boolean softCommit)
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

commit

public UpdateResponse commit(boolean waitFlush,
                             boolean waitSearcher,
                             boolean softCommit)
                      throws SolrServerException,
                             IOException

Overrides:

commit in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize(String collection)
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize()
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize(String collection,
                               boolean waitFlush,
                               boolean waitSearcher)
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize(boolean waitFlush,
                               boolean waitSearcher)
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize(String collection,
                               boolean waitFlush,
                               boolean waitSearcher,
                               int maxSegments)
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

optimize

public UpdateResponse optimize(boolean waitFlush,
                               boolean waitSearcher,
                               int maxSegments)
                        throws SolrServerException,
                               IOException

Overrides:

optimize in class SolrClient

Throws:

SolrServerException

IOException

rollback

public UpdateResponse rollback(String collection)
                        throws SolrServerException,
                               IOException

Overrides:

rollback in class SolrClient

Throws:

SolrServerException

IOException

rollback

public UpdateResponse rollback()
                        throws SolrServerException,
                               IOException

Overrides:

rollback in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String collection,
                                 String id)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String id)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String collection,
                                 String id,
                                 int commitWithinMs)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String id,
                                 int commitWithinMs)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String collection,
                                 List<String> ids)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(List<String> ids)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(String collection,
                                 List<String> ids,
                                 int commitWithinMs)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteById

public UpdateResponse deleteById(List<String> ids,
                                 int commitWithinMs)
                          throws SolrServerException,
                                 IOException

Overrides:

deleteById in class SolrClient

Throws:

SolrServerException

IOException

deleteByQuery

public UpdateResponse deleteByQuery(String collection,
                                    String query)
                             throws SolrServerException,
                                    IOException

Overrides:

deleteByQuery in class SolrClient

Throws:

SolrServerException

IOException

deleteByQuery

public UpdateResponse deleteByQuery(String query)
                             throws SolrServerException,
                                    IOException

Overrides:

deleteByQuery in class SolrClient

Throws:

SolrServerException

IOException

deleteByQuery

public UpdateResponse deleteByQuery(String collection,
                                    String query,
                                    int commitWithinMs)
                             throws SolrServerException,
                                    IOException

Overrides:

deleteByQuery in class SolrClient

Throws:

SolrServerException

IOException

deleteByQuery

public UpdateResponse deleteByQuery(String query,
                                    int commitWithinMs)
                             throws SolrServerException,
                                    IOException

Overrides:

deleteByQuery in class SolrClient

Throws:

SolrServerException

IOException