AbstractAmetysConcurrentUpdateClient (Ametys 4.2.x

java.lang.Object
- org.apache.solr.client.solrj.SolrClient
- - org.apache.solr.client.solrj.impl.ConcurrentUpdateSolrClient
  - - org.ametys.cms.search.solr.AbstractAmetysConcurrentUpdateClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable

Direct Known Subclasses:

DefaultUpdateClient, NoAutoCommitUpdateClient
```
public abstract class AbstractAmetysConcurrentUpdateClient
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

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
`AbstractAmetysConcurrentUpdateClient(String solrServerUrl, String collectionName, int queueSize, int threadCount, Logger logger)` Constructor

Method Summary

All Methods Instance Methods Concrete Methods
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

AbstractAmetysConcurrentUpdateClient

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

Class AbstractAmetysConcurrentUpdateClient

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

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

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

Methods inherited from class java.lang.Object

Field Detail

_collectionName

_logger

Constructor Detail

AbstractAmetysConcurrentUpdateClient

Method Detail

handleError

onSuccess

_checkCollectionInUse

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

optimize

optimize

optimize

optimize

optimize

optimize

rollback

rollback

deleteById

deleteById

deleteById

deleteById

deleteById

deleteById

deleteById

deleteById

deleteByQuery

deleteByQuery

deleteByQuery

deleteByQuery