Package org.elasticsearch.transport

Class RequestHandlerRegistry<Request extends TransportRequest>

java.lang.Object

org.elasticsearch.transport.RequestHandlerRegistry<Request>

public class RequestHandlerRegistry<Request extends TransportRequest>
extends Object

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

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

public String getAction()

newRequest

public Request newRequest(StreamInput in)
                   throws IOException

Throws:

IOException

processMessageReceived

public void processMessageReceived(Request request,
 TransportChannel channel)
                            throws Exception

Throws:

Exception

isForceExecution

public boolean isForceExecution()

canTripCircuitBreaker

public boolean canTripCircuitBreaker()

getExecutor

public String getExecutor()

getHandler

public TransportRequestHandler<Request> getHandler()

toString

public String toString()

Overrides:

toString in class Object

replaceHandler

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