public interface LeaderSessionMessageFilter extends FlinkActor
LeaderSessionMessage
which contain an invalid leader session id.
Messages which contain a valid leader session ID are unwrapped and forwarded to the actor.
Modifier and Type | Method and Description |
---|---|
Object |
decorateMessage(Object message)
Wrap
RequiresLeaderSessionID messages in a LeaderSessionMessage |
void |
handleDiscardedMessage(UUID expectedLeaderSessionID,
JobManagerMessages.LeaderSessionMessage msg) |
void |
handleNoLeaderId(JobManagerMessages.LeaderSessionMessage msg) |
scala.Option<UUID> |
leaderSessionID() |
scala.PartialFunction<Object,scala.runtime.BoxedUnit> |
receive() |
handleMessage, log
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
scala.Option<UUID> leaderSessionID()
scala.PartialFunction<Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
receive
in interface FlinkActor
void handleDiscardedMessage(UUID expectedLeaderSessionID, JobManagerMessages.LeaderSessionMessage msg)
void handleNoLeaderId(JobManagerMessages.LeaderSessionMessage msg)
Object decorateMessage(Object message)
RequiresLeaderSessionID
messages in a LeaderSessionMessage
decorateMessage
in interface FlinkActor
message
- The message to decorateCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.