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()`
`TransportRequestHandler<Request>`	`getHandler()`
`boolean`	`isForceExecution()`
`Request`	`newRequest(StreamInput in)`
`void`	`processMessageReceived(Request request, TransportChannel channel)`
`static <R extends TransportRequest> RequestHandlerRegistry<R>`	`replaceHandler(RequestHandlerRegistry<R> registry, TransportRequestHandler<R> handler)`
`java.lang.String`	`toString()`

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- 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 Details
- 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()
- getHandler
  
  public TransportRequestHandler<Request> getHandler()
- toString
  
  public java.lang.String toString()
  
  Overrides:
  
  toString in class java.lang.Object
- replaceHandler
  
  public static <R extends TransportRequest> RequestHandlerRegistry<R> replaceHandler(RequestHandlerRegistry<R> registry, TransportRequestHandler<R> handler)