org.apache.flink.runtime.rpc.akka

Class FencedAkkaRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway>

java.lang.Object

akka.actor.AbstractActor

org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor<F,T>

Type Parameters:

F - type of the fencing token

T - type of the RpcEndpoint

All Implemented Interfaces:

akka.actor.Actor

public class FencedAkkaRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway>
extends akka.actor.AbstractActor

Fenced extension of the AkkaRpcActor. This actor will be started for FencedRpcEndpoint and is responsible for filtering out invalid messages with respect to the current fencing token.

Nested Class Summary

Nested classes/interfaces inherited from class akka.actor.AbstractActor

akka.actor.AbstractActor.ActorContext, akka.actor.AbstractActor.Receive

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	log
protected T	rpcEndpoint the endpoint to invoke the methods on.

Constructor Summary

Constructors

Constructor and Description
FencedAkkaRpcActor(T rpcEndpoint, CompletableFuture<Boolean> terminationFuture, int version, long maximumFramesize)

Method Summary

Modifier and Type	Method and Description
akka.actor.AbstractActor.Receive	createReceive()
protected Object	envelopeSelfMessage(Object message) Hook to envelope self messages.
protected void	handleRpcMessage(Object message)
void	postStop()
protected void	sendErrorIfSender(Throwable throwable) Send throwable to sender if the sender is specified.

Methods inherited from class akka.actor.AbstractActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, emptyBehavior, getContext, getSelf, getSender, postRestart, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.slf4j.Logger log

rpcEndpoint

protected final T extends RpcEndpoint & RpcGateway rpcEndpoint

the endpoint to invoke the methods on.

Constructor Detail

FencedAkkaRpcActor

public FencedAkkaRpcActor(T rpcEndpoint,
                          CompletableFuture<Boolean> terminationFuture,
                          int version,
                          long maximumFramesize)

Method Detail

handleRpcMessage

protected void handleRpcMessage(Object message)

envelopeSelfMessage

protected Object envelopeSelfMessage(Object message)

Hook to envelope self messages.

Parameters:

message - to envelope

Returns:

enveloped message

postStop

public void postStop()
              throws Exception

Specified by:

postStop in interface akka.actor.Actor

Overrides:

postStop in class akka.actor.AbstractActor

Throws:

Exception

createReceive

public akka.actor.AbstractActor.Receive createReceive()

Specified by:

createReceive in class akka.actor.AbstractActor

sendErrorIfSender

protected void sendErrorIfSender(Throwable throwable)

Send throwable to sender if the sender is specified.

Parameters:

throwable - to send to the sender