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)
         {