_count hangs, closes #52

kimchy · kimchy · commit 83a78b397987 · 2010-03-09T13:25:17.000+02:00
diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/client/server/ServerClient.java b/modules/elasticsearch/src/main/java/org/elasticsearch/client/server/ServerClient.java
@@ -49,7 +49,7 @@
 import org.elasticsearch.util.settings.Settings;
 
 /**
- * @author kimchy (Shay Banon)
+ * @author kimchy (shay.banon)
  */
 public class ServerClient extends AbstractComponent implements Client {
 
@@ -136,7 +136,7 @@ public class ServerClient extends AbstractComponent implements Client {
     }
 
     @Override public void count(CountRequest request, ActionListener<CountResponse> listener) {
-        countAction.execute(request);
+        countAction.execute(request, listener);
     }
 
     @Override public ActionFuture<SearchResponse> search(SearchRequest request) {

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@`
`49`	`49`	`import org.elasticsearch.util.settings.Settings;`
`50`	`50`
`51`	`51`	`/**`
`52`		`- * @author kimchy (Shay Banon)`
	`52`	`+ * @author kimchy (shay.banon)`
`53`	`53`	`*/`
`54`	`54`	`public class ServerClient extends AbstractComponent implements Client {`
`55`	`55`
`@@ -136,7 +136,7 @@ public class ServerClient extends AbstractComponent implements Client {`
`136`	`136`	`}`
`137`	`137`
`138`	`138`	`@Override public void count(CountRequest request, ActionListener<CountResponse> listener) {`
`139`		`- countAction.execute(request);`
	`139`	`+ countAction.execute(request, listener);`
`140`	`140`	`}`
`141`	`141`
`142`	`142`	`@Override public ActionFuture<SearchResponse> search(SearchRequest request) {`