public class ConcurrentUpdateSolrServer extends SolrServer
HttpSolrServer
is better suited for the
query interface.Constructor and Description |
---|
ConcurrentUpdateSolrServer(String solrServerUrl,
org.apache.http.client.HttpClient client,
int queueSize,
int threadCount)
Uses the supplied HttpClient to send documents to the Solr server, the
HttpClient should be instantiated using a
ThreadSafeClientConnManager.
|
ConcurrentUpdateSolrServer(String solrServerUrl,
int queueSize,
int threadCount)
Uses an internal ThreadSafeClientConnManager to manage http
connections.
|
Modifier and Type | Method and Description |
---|---|
void |
blockUntilFinished() |
void |
handleError(Throwable ex) |
NamedList<Object> |
request(SolrRequest request)
SolrServer implementations need to implement how a request is actually processed
|
void |
setParser(ResponseParser responseParser) |
void |
setRequestWriter(RequestWriter requestWriter) |
void |
shutdown() |
void |
shutdownNow() |
add, add, add, add, addBean, addBean, addBeans, addBeans, commit, commit, deleteById, deleteById, deleteById, deleteById, deleteByQuery, deleteByQuery, getBinder, optimize, optimize, optimize, ping, query, query, rollback
public ConcurrentUpdateSolrServer(String solrServerUrl, int queueSize, int threadCount) throws MalformedURLException
solrServerUrl
- The Solr server URLqueueSize
- The buffer size before the documents are sent to the serverthreadCount
- The number of background threads used to empty the queueMalformedURLException
public ConcurrentUpdateSolrServer(String solrServerUrl, org.apache.http.client.HttpClient client, int queueSize, int threadCount) throws MalformedURLException
MalformedURLException
public NamedList<Object> request(SolrRequest request) throws SolrServerException, IOException
SolrServer
request
in class SolrServer
SolrServerException
IOException
public void blockUntilFinished()
public void handleError(Throwable ex)
public void shutdown()
public void shutdownNow()
public void setParser(ResponseParser responseParser)
public void setRequestWriter(RequestWriter requestWriter)