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<Void> internalTerminationFuture) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleMessage(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<Void> internalTerminationFuture)
protected void handleMessage(Object message)
public 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–2018 The Apache Software Foundation. All rights reserved.