Package org.elasticsearch.transport

Class RequestHandlerRegistry<Request extends TransportRequest>

org.elasticsearch.transport.RequestHandlerRegistry<Request>

public class RequestHandlerRegistry<Request extends TransportRequest>
extends 

Constructor Summary

Constructors

Constructor	Description
action, Writeable.Reader<Request> requestReader, TaskManager taskManager, TransportRequestHandler<Request> handler, executor, boolean forceExecution, boolean canTripCircuitBreaker)

Method Summary

Modifier and Type	Method	Description
boolean	canTripCircuitBreaker()
	getAction()
	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)
	toString()

Methods inherited from class java.lang.

, , , , , , , , ,

Constructor Details

RequestHandlerRegistry

public RequestHandlerRegistry( action,
 Writeable.Reader<Request> requestReader,
 TaskManager taskManager,
 TransportRequestHandler<Request> handler,
  executor,
 boolean forceExecution,
 boolean canTripCircuitBreaker)

Method Details

getAction

public  getAction()

newRequest

public Request newRequest(StreamInput in)
                   throws 

Throws:

processMessageReceived

public void processMessageReceived(Request request,
 TransportChannel channel)
                            throws 

Throws:

isForceExecution

public boolean isForceExecution()

canTripCircuitBreaker

public boolean canTripCircuitBreaker()

getExecutor

public  getExecutor()

getHandler

public TransportRequestHandler<Request> getHandler()

toString

public  toString()

Overrides:

in class

replaceHandler

public static <R extends TransportRequest>
RequestHandlerRegistry<R> replaceHandler(RequestHandlerRegistry<R> registry,
 TransportRequestHandler<R> handler)