Package org.elasticsearch.transport
Class RequestHandlerRegistry<Request extends TransportRequest>
- java.lang.Object
-
- org.elasticsearch.transport.RequestHandlerRegistry<Request>
-
public class RequestHandlerRegistry<Request extends TransportRequest> extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description RequestHandlerRegistry(java.lang.String action, Writeable.Reader<Request> requestReader, TaskManager taskManager, TransportRequestHandler<Request> handler, java.lang.String executor, boolean forceExecution, boolean canTripCircuitBreaker)
-
Method Summary
Modifier and Type Method Description boolean
canTripCircuitBreaker()
java.lang.String
getAction()
java.lang.String
getExecutor()
boolean
isForceExecution()
Request
newRequest(StreamInput in)
void
processMessageReceived(Request request, TransportChannel channel)
java.lang.String
toString()
-
-
-
Constructor Detail
-
RequestHandlerRegistry
public RequestHandlerRegistry(java.lang.String action, Writeable.Reader<Request> requestReader, TaskManager taskManager, TransportRequestHandler<Request> handler, java.lang.String executor, boolean forceExecution, boolean canTripCircuitBreaker)
-
-
Method Detail
-
getAction
public java.lang.String getAction()
-
newRequest
public Request newRequest(StreamInput in) throws java.io.IOException
- Throws:
java.io.IOException
-
processMessageReceived
public void processMessageReceived(Request request, TransportChannel channel) throws java.lang.Exception
- Throws:
java.lang.Exception
-
isForceExecution
public boolean isForceExecution()
-
canTripCircuitBreaker
public boolean canTripCircuitBreaker()
-
getExecutor
public java.lang.String getExecutor()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-