You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@opennlp.apache.org by jo...@apache.org on 2011/11/03 14:57:44 UTC
svn commit: r1197121 -
/incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java
Author: joern
Date: Thu Nov 3 13:57:44 2011
New Revision: 1197121
URL: http://svn.apache.org/viewvc?rev=1197121&view=rev
Log:
OPENNLP-354 Specified timeout and fixed error handling.
Modified:
incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java
Modified: incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java
URL: http://svn.apache.org/viewvc/incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java?rev=1197121&r1=1197120&r2=1197121&view=diff
==============================================================================
--- incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java (original)
+++ incubator/opennlp/sandbox/caseditor-corpus-server-plugin/src/main/java/org/apache/opennlp/corpus_server/caseditor/SearchCorpusServerJob.java Thu Nov 3 13:57:44 2011
@@ -54,17 +54,24 @@ public class SearchCorpusServerJob exten
protected IStatus run(IProgressMonitor monitor) {
Client c = Client.create();
-
+ c.setConnectTimeout(10000);
WebResource r = c.resource(serverAddress);
- ClientResponse response = r
- .path("_search")
- .queryParam("q", searchQuery)
- .accept(MediaType.APPLICATION_JSON)
- .get(ClientResponse.class);
-
+ ClientResponse response;
+
+ try {
+ response = r
+ .path("_search")
+ .queryParam("q", searchQuery)
+ .accept(MediaType.APPLICATION_JSON)
+ .get(ClientResponse.class);
+ }
+ catch (com.sun.jersey.api.client.ClientHandlerException e) {
+ return new Status(IStatus.WARNING, CorpusServerPlugin.PLUGIN_ID, "Failed to connect to server!");
+ }
+
if (response.getClientResponseStatus().getStatusCode() != 200) {
- return new Status(IStatus.OK, CorpusServerPlugin.PLUGIN_ID, "Failed to retrieve results from server!");
+ return new Status(IStatus.WARNING, CorpusServerPlugin.PLUGIN_ID, "Failed to retrieve results from server!");
}
searchResult = response.getEntity(JSONArray.class);