package tech.powerjob.remote.akka;

import akka.actor.AbstractActor;
import akka.actor.DeadLetter;
import lombok.extern.slf4j.Slf4j;

/**
 * TroubleshootingActor
 *
 * @author tjq
 * @since 2022/12/31
 */
@Slf4j
public class AkkaTroubleshootingActor extends AbstractActor {
    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(DeadLetter.class, this::onReceiveDeadLetter)
                .build();
    }

    public void onReceiveDeadLetter(DeadLetter dl) {
        log.warn("[PowerJob-AKKA] receive DeadLetter: {}", dl);
    }
}