You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2012/12/31 22:42:34 UTC
svn commit: r1427246 -
/manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java
Author: kwright
Date: Mon Dec 31 21:42:34 2012
New Revision: 1427246
URL: http://svn.apache.org/viewvc?rev=1427246&view=rev
Log:
Hook up ping.
Modified:
manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java
Modified: manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java?rev=1427246&r1=1427245&r2=1427246&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java (original)
+++ manifoldcf/branches/CONNECTORS-594/connectors/solr/connector/src/main/java/org/apache/manifoldcf/agents/output/solr/HttpPoster.java Mon Dec 31 21:42:34 2012
@@ -58,6 +58,8 @@ import org.apache.solr.client.solrj.impl
import org.apache.solr.client.solrj.request.ContentStreamUpdateRequest;
import org.apache.solr.client.solrj.impl.XMLResponseParser;
import org.apache.solr.common.util.ContentStreamBase;
+import org.apache.solr.client.solrj.response.SolrPingResponse;
+import org.apache.solr.client.solrj.response.UpdateResponse;
/**
* Posts an input stream to SOLR
@@ -906,7 +908,7 @@ public class HttpPoster
// Open a socket to ingest, and to the response stream to get the post result
try
{
- solrServer.deleteById(documentURI);
+ UpdateResponse response = solrServer.deleteById(documentURI);
// Success
activityStart = new Long(fullStartTime);
@@ -988,7 +990,7 @@ public class HttpPoster
try
{
// Do the operation!
- solrServer.commit();
+ UpdateResponse response = solrServer.commit();
}
catch (InterruptedIOException ioe)
{
@@ -1037,9 +1039,7 @@ public class HttpPoster
// Do the operation!
try
{
- // MHL to check status via SolrJ
- if (false)
- throw new IOException("blah");
+ SolrPingResponse response = solrServer.ping();
}
catch (InterruptedIOException ioe)
{