Class RequestHandlerRegistry<Request extends TransportRequest>


  • public class RequestHandlerRegistry<Request extends TransportRequest>
    extends java.lang.Object
    • 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 class java.lang.Object