Java源码示例:org.elasticsearch.action.ActionType
示例1
/**
* Execute a transport action and handle response with the provided listener.
* @param <Request> ActionRequest
* @param <Response> ActionResponse
* @param action transport action
* @param request request body
* @param listener needed to handle response
*/
public <Request extends ActionRequest, Response extends ActionResponse> void execute(
ActionType<Response> action,
Request request,
ActionListener<Response> listener
) {
client
.execute(
action,
request,
ActionListener.wrap(response -> { listener.onResponse(response); }, exception -> { listener.onFailure(exception); })
);
}
示例2
@Override
public <Request extends ActionRequest, Response extends ActionResponse> ActionFuture<Response> execute(
final ActionType<Response> action, final Request request) {
return client.execute(action, request);
}
示例3
@Override
public <Request extends ActionRequest, Response extends ActionResponse> void execute(final ActionType<Response> action,
final Request request, final ActionListener<Response> listener) {
client.execute(action, request, listener);
}