public final class TransportActionProxy
extends java.lang.Object
Modifier and Type | Method | 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,
java.util.function.Function<TransportRequest,java.util.function.Supplier<TransportResponse>> responseFunction) |
Registers a proxy request handler that allows to forward requests for the given action to another node.
|
static void |
registerProxyAction(TransportService service,
java.lang.String action,
java.util.function.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, java.util.function.Function<TransportRequest,java.util.function.Supplier<TransportResponse>> responseFunction)
public static void registerProxyAction(TransportService service, java.lang.String action, java.util.function.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