F
- type of the fencing tokenT
- type of the RpcEndpointpublic class FencedAkkaRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway>
extends akka.actor.UntypedActor
AkkaRpcActor
. This actor will be started for FencedRpcEndpoint
and is
responsible for filtering out invalid messages with respect to the current fencing token.Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
log |
protected T |
rpcEndpoint
the endpoint to invoke the methods on.
|
Constructor and Description |
---|
FencedAkkaRpcActor(T rpcEndpoint,
CompletableFuture<Boolean> terminationFuture,
int version) |
Modifier and Type | Method and Description |
---|---|
protected Object |
envelopeSelfMessage(Object message)
Hook to envelope self messages.
|
protected void |
handleRpcMessage(Object message) |
void |
onReceive(Object message) |
void |
postStop() |
protected void |
sendErrorIfSender(Throwable throwable)
Send throwable to sender if the sender is specified.
|
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
protected final org.slf4j.Logger log
protected final T extends RpcEndpoint & RpcGateway rpcEndpoint
public FencedAkkaRpcActor(T rpcEndpoint, CompletableFuture<Boolean> terminationFuture, int version)
protected void handleRpcMessage(Object message)
protected Object envelopeSelfMessage(Object message)
message
- to envelopepublic void postStop() throws Exception
postStop
in interface akka.actor.Actor
postStop
in class akka.actor.UntypedActor
Exception
public void onReceive(Object message)
onReceive
in class akka.actor.UntypedActor
protected void sendErrorIfSender(Throwable throwable)
throwable
- to send to the senderCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.