Struct riker_deadletter::DeadLettersActor

pub struct DeadLettersActor<Msg: Message> { /* private fields */ }

Trait Implementations

impl<Msg: Message> Actor for DeadLettersActor<Msg>

type Msg = Msg

fn pre_start(&mut self, ctx: &Context<Self::Msg>)

Invoked when an actor is being started by the system.

fn other_receive(
    &mut self,
    _: &Context<Msg>,
    msg: ActorMsg<Msg>,
    _: Option<ActorRef<Msg>>
)

Invoked when an actor receives a Riker predefined message

fn receive(&mut self, _: &Context<Msg>, _: Msg, _: Option<ActorRef<Msg>>)

Invoked when an actor receives a message

fn post_start(&mut self, ctx: &Context<Self::Msg>)

Invoked after an actor has started.

fn post_stop(&mut self)

Invoked after an actor has been stopped.

fn system_receive(
    &mut self,
    ctx: &Context<Self::Msg>,
    msg: SystemMsg<Self::Msg>,
    sender: Option<ActorRef<Self::Msg>>
)

Invoked when an actor receives a Riker system message

fn persistence_conf(&self) -> Option<PersistenceConf>

Return a Some(PersistenceConf) to enable actor persistence.

fn apply_event(&mut self, ctx: &Context<Self::Msg>, evt: Self::Msg)

Invoked after an event is successfully inserted into the event store.

fn replay_event(&mut self, ctx: &Context<Self::Msg>, evt: Self::Msg)

Invoked for each event when the actor is recovering.

fn supervisor_strategy(&self) -> Strategy

Return a supervisor strategy that will be used when handling failed child actors.

impl<Msg: Message> DeadLetterProps for DeadLettersActor<Msg>

type Msg = Msg

fn props(dl: ActorRef<Msg>) -> BoxActorProd<Msg>