F
- type of the fencing tokenT
- type of the RpcEndpointpublic class FencedPekkoRpcActor<F extends Serializable,T extends FencedRpcEndpoint<F> & RpcGateway>
extends org.apache.pekko.actor.AbstractActor
PekkoRpcActor
. 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 |
---|
FencedPekkoRpcActor(T rpcEndpoint,
CompletableFuture<Boolean> terminationFuture,
int version,
long maximumFramesize,
boolean forceSerialization,
ClassLoader flinkClassLoader) |
Modifier and Type | Method and Description |
---|---|
org.apache.pekko.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.
|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, emptyBehavior, getContext, getSelf, getSender, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled
protected final org.slf4j.Logger log
protected final T extends RpcEndpoint & RpcGateway rpcEndpoint
public FencedPekkoRpcActor(T rpcEndpoint, CompletableFuture<Boolean> terminationFuture, int version, long maximumFramesize, boolean forceSerialization, ClassLoader flinkClassLoader)
protected void handleRpcMessage(Object message)
protected Object envelopeSelfMessage(Object message)
message
- to envelopepublic void postStop() throws Exception
postStop
in interface org.apache.pekko.actor.Actor
postStop
in class org.apache.pekko.actor.AbstractActor
Exception
public org.apache.pekko.actor.AbstractActor.Receive createReceive()
createReceive
in class org.apache.pekko.actor.AbstractActor
protected void sendErrorIfSender(Throwable throwable)
throwable
- to send to the senderCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.