public final class TransportActionProxy
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
getProxyAction(java.lang.String action)
Returns the corresponding proxy action for the given action
|
static boolean |
isProxyAction(java.lang.String action)
Returns
true iff the given action is a proxy action |
static boolean |
isProxyRequest(TransportRequest request)
Returns
true iff the given request is a proxy request |
static void |
registerProxyAction(TransportService service,
java.lang.String action,
org.apache.logging.log4j.util.Supplier<TransportResponse> responseSupplier)
Registers a proxy request handler that allows to forward requests for the given action to another node.
|
static TransportRequest |
unwrapRequest(TransportRequest request)
Unwraps a proxy request and returns the original request
|
static TransportRequest |
wrapRequest(DiscoveryNode node,
TransportRequest request)
Wraps the actual request in a proxy request object that encodes the target node.
|
public static void registerProxyAction(TransportService service, java.lang.String action, org.apache.logging.log4j.util.Supplier<TransportResponse> responseSupplier)
public static java.lang.String getProxyAction(java.lang.String action)
public static TransportRequest wrapRequest(DiscoveryNode node, TransportRequest request)
public static TransportRequest unwrapRequest(TransportRequest request)
public static boolean isProxyAction(java.lang.String action)
true
iff the given action is a proxy actionpublic static boolean isProxyRequest(TransportRequest request)
true
iff the given request is a proxy request