F
- type of the fencing tokenpublic abstract class FencedRpcEndpoint<F extends Serializable> extends RpcEndpoint
RpcEndpoint
. A fenced rpc endpoint expects all rpc messages being
enriched with fencing tokens. Furthermore, the rpc endpoint has its own fencing token assigned.
The rpc is then only executed if the attached fencing token equals the endpoint's own token.RpcEndpoint.MainThreadExecutor
log, rpcServer
Modifier | Constructor and Description |
---|---|
protected |
FencedRpcEndpoint(RpcService rpcService,
F fencingToken) |
protected |
FencedRpcEndpoint(RpcService rpcService,
String endpointId,
F fencingToken) |
Modifier and Type | Method and Description |
---|---|
F |
getFencingToken() |
callAsync, closeAsync, getAddress, getEndpointId, getHostname, getMainThreadExecutor, getRpcService, getSelfGateway, getTerminationFuture, internalCallOnStart, internalCallOnStop, isRunning, onStart, onStop, registerResource, runAsync, scheduleRunAsync, scheduleRunAsync, start, stop, unregisterResource, validateRunsInMainThread
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected FencedRpcEndpoint(RpcService rpcService, String endpointId, F fencingToken)
protected FencedRpcEndpoint(RpcService rpcService, F fencingToken)
public F getFencingToken()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.