summaryrefslogtreecommitdiff
path: root/core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java')
-rw-r--r--core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java b/core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java
index 9b1ae9b269..54f55e187a 100644
--- a/core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java
+++ b/core/src/main/java/org/elasticsearch/action/support/ActionFilterChain.java
@@ -27,17 +27,17 @@ import org.elasticsearch.tasks.Task;
/**
* A filter chain allowing to continue and process the transport action request
*/
-public interface ActionFilterChain {
+public interface ActionFilterChain<Request extends ActionRequest<Request>, Response extends ActionResponse> {
/**
* Continue processing the request. Should only be called if a response has not been sent through
* the given {@link ActionListener listener}
*/
- void proceed(Task task, final String action, final ActionRequest request, final ActionListener listener);
+ void proceed(Task task, final String action, final Request request, final ActionListener<Response> listener);
/**
* Continue processing the response. Should only be called if a response has not been sent through
* the given {@link ActionListener listener}
*/
- void proceed(final String action, final ActionResponse response, final ActionListener listener);
+ void proceed(final String action, final Response response, final ActionListener<Response> listener);
}