Package org.apache.flink.runtime.rpc.pekko

Class DeadLettersActor

  • All Implemented Interfaces:
    org.apache.pekko.actor.Actor
    public class DeadLettersActor
extends org.apache.pekko.actor.AbstractActor
    Actor which listens to DeadLetter and responds with a failure if the message was a RPC.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.pekko.actor.AbstractActor

        org.apache.pekko.actor.AbstractActor.ActorContext, org.apache.pekko.actor.AbstractActor.Receive

      • Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor

        org.apache.pekko.actor.Actor.emptyBehavior$, org.apache.pekko.actor.Actor.ignoringBehavior$

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.pekko.actor.AbstractActor.Receive createReceive()  
      static org.apache.pekko.actor.Props getProps()  

      • Methods inherited from class org.apache.pekko.actor.AbstractActor

        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, postStop, preRestart, preRestart, preStart, receive, receiveBuilder, self, sender, supervisorStrategy, unhandled

    • Constructor Detail

      • DeadLettersActor

        public DeadLettersActor()

    • Method Detail

      • createReceive

        public org.apache.pekko.actor.AbstractActor.Receive createReceive()
        Specified by:
        createReceive in class org.apache.pekko.actor.AbstractActor

      • getProps

        public static org.apache.pekko.actor.Props getProps()