Package org.elasticsearch.action.support
Class ListenerTimeouts
- java.lang.Object
-
- org.elasticsearch.action.support.ListenerTimeouts
-
public class ListenerTimeouts extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description ListenerTimeouts()
-
Method Summary
Modifier and Type Method Description static <Response> ActionListener<Response>
wrapWithTimeout(ThreadPool threadPool, ActionListener<Response> listener, TimeValue timeout, java.lang.String executor, java.lang.String listenerName)
Wraps a listener with a listener that can timeout.
-
-
-
Method Detail
-
wrapWithTimeout
public static <Response> ActionListener<Response> wrapWithTimeout(ThreadPool threadPool, ActionListener<Response> listener, TimeValue timeout, java.lang.String executor, java.lang.String listenerName)
Wraps a listener with a listener that can timeout. After the timeout period theActionListener.onFailure(Exception)
will be called with aElasticsearchTimeoutException
if the listener has not already been completed.- Parameters:
threadPool
- used to schedule the timeoutlistener
- to that can timeouttimeout
- period before listener failedexecutor
- to use for scheduling timeoutlistenerName
- name of the listener for timeout exception- Returns:
- the wrapped listener that will timeout
-
-