Package org.elasticsearch.transport
Class RequestHandlerRegistry<Request extends TransportRequest>
java.lang.Object
org.elasticsearch.transport.RequestHandlerRegistry<Request>
-
Constructor Summary
ConstructorDescriptionRequestHandlerRegistry
(String action, Writeable.Reader<Request> requestReader, TaskManager taskManager, TransportRequestHandler<Request> handler, String executor, boolean forceExecution, boolean canTripCircuitBreaker) -
Method Summary
Modifier and TypeMethodDescriptionboolean
boolean
void
processMessageReceived
(Request request, TransportChannel channel) static <R extends TransportRequest>
RequestHandlerRegistry<R>replaceHandler
(RequestHandlerRegistry<R> registry, TransportRequestHandler<R> handler) toString()
-
Constructor Details
-
RequestHandlerRegistry
public RequestHandlerRegistry(String action, Writeable.Reader<Request> requestReader, TaskManager taskManager, TransportRequestHandler<Request> handler, String executor, boolean forceExecution, boolean canTripCircuitBreaker)
-
-
Method Details
-
getAction
-
newRequest
- Throws:
IOException
-
processMessageReceived
- Throws:
Exception
-
isForceExecution
public boolean isForceExecution() -
canTripCircuitBreaker
public boolean canTripCircuitBreaker() -
getExecutor
-
getHandler
-
toString
-
replaceHandler
public static <R extends TransportRequest> RequestHandlerRegistry<R> replaceHandler(RequestHandlerRegistry<R> registry, TransportRequestHandler<R> handler)
-