honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rename RequestBuilder to ActionRequestBuilder and have a request() method on the actual interface

This commit is contained in:
Shay Banon 2012-01-15 12:14:57 +02:00
parent 6ff15b928c
commit c3c5aec567
4 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/elasticsearch/client/action/RequestBuilder.java → src/main/java/org/elasticsearch/client/action/ActionRequestBuilder.java
View File

@ -27,7 +27,9 @@ import org.elasticsearch.action.ListenableActionFuture;
/** /**
* *
*/ */
public interface RequestBuilder<Request extends ActionRequest, Response extends ActionResponse> { public interface ActionRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> {
Request request();
ListenableActionFuture<Response> execute(); ListenableActionFuture<Response> execute();

9
src/main/java/org/elasticsearch/client/action/admin/cluster/support/BaseClusterRequestBuilder.java
View File

@ -25,13 +25,13 @@ import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.ListenableActionFuture; import org.elasticsearch.action.ListenableActionFuture;
import org.elasticsearch.action.support.PlainListenableActionFuture; import org.elasticsearch.action.support.PlainListenableActionFuture;
import org.elasticsearch.client.ClusterAdminClient; import org.elasticsearch.client.ClusterAdminClient;
import org.elasticsearch.client.action.RequestBuilder; import org.elasticsearch.client.action.ActionRequestBuilder;
import org.elasticsearch.client.internal.InternalClusterAdminClient; import org.elasticsearch.client.internal.InternalClusterAdminClient;
/** /**
* *
*/ */
public abstract class BaseClusterRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements RequestBuilder<Request, Response> { public abstract class BaseClusterRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements ActionRequestBuilder<Request, Response> {
protected final InternalClusterAdminClient client; protected final InternalClusterAdminClient client;
@ -42,6 +42,11 @@ public abstract class BaseClusterRequestBuilder<Request extends ActionRequest, R
this.request = request; this.request = request;
} }
@Override
public Request request() {
return request;
}
@Override @Override
public ListenableActionFuture<Response> execute() { public ListenableActionFuture<Response> execute() {
PlainListenableActionFuture<Response> future = new PlainListenableActionFuture<Response>(request.listenerThreaded(), client.threadPool()); PlainListenableActionFuture<Response> future = new PlainListenableActionFuture<Response>(request.listenerThreaded(), client.threadPool());

9
src/main/java/org/elasticsearch/client/action/admin/indices/support/BaseIndicesRequestBuilder.java
View File

@ -25,13 +25,13 @@ import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.ListenableActionFuture; import org.elasticsearch.action.ListenableActionFuture;
import org.elasticsearch.action.support.PlainListenableActionFuture; import org.elasticsearch.action.support.PlainListenableActionFuture;
import org.elasticsearch.client.IndicesAdminClient; import org.elasticsearch.client.IndicesAdminClient;
import org.elasticsearch.client.action.RequestBuilder; import org.elasticsearch.client.action.ActionRequestBuilder;
import org.elasticsearch.client.internal.InternalIndicesAdminClient; import org.elasticsearch.client.internal.InternalIndicesAdminClient;
/** /**
* *
*/ */
public abstract class BaseIndicesRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements RequestBuilder<Request, Response> { public abstract class BaseIndicesRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements ActionRequestBuilder<Request, Response> {
protected final InternalIndicesAdminClient client; protected final InternalIndicesAdminClient client;
@ -42,6 +42,11 @@ public abstract class BaseIndicesRequestBuilder<Request extends ActionRequest, R
this.request = request; this.request = request;
} }
@Override
public Request request() {
return request;
}
@Override @Override
public ListenableActionFuture<Response> execute() { public ListenableActionFuture<Response> execute() {
PlainListenableActionFuture<Response> future = new PlainListenableActionFuture<Response>(request.listenerThreaded(), client.threadPool()); PlainListenableActionFuture<Response> future = new PlainListenableActionFuture<Response>(request.listenerThreaded(), client.threadPool());

4
src/main/java/org/elasticsearch/client/action/support/BaseRequestBuilder.java
View File

@ -25,13 +25,13 @@ import org.elasticsearch.action.ActionResponse;
import org.elasticsearch.action.ListenableActionFuture; import org.elasticsearch.action.ListenableActionFuture;
import org.elasticsearch.action.support.PlainListenableActionFuture; import org.elasticsearch.action.support.PlainListenableActionFuture;
import org.elasticsearch.client.Client; import org.elasticsearch.client.Client;
import org.elasticsearch.client.action.RequestBuilder; import org.elasticsearch.client.action.ActionRequestBuilder;
import org.elasticsearch.client.internal.InternalClient; import org.elasticsearch.client.internal.InternalClient;
/** /**
* *
*/ */
public abstract class BaseRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements RequestBuilder<Request, Response> { public abstract class BaseRequestBuilder<Request extends ActionRequest, Response extends ActionResponse> implements ActionRequestBuilder<Request, Response> {
protected final InternalClient client; protected final InternalClient client;