如何使用BehaviorTestKit测试MessageAdapter效果

import akka.actor.ActorSystem;
import akka.actor.testkit.typed.javadsl.BehaviorTestKit;
import akka.actor.typed.ActorRef;
import akka.actor.typed.Behavior;
import akka.actor.typed.javadsl.Behaviors;
import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertEquals;

public class MessageAdapterTest {

    // 定义一个消息类型
    static class Message {
        private final String content;

        public Message(String content) {
            this.content = content;
        }

        public String getContent() {
            return content;
        }
    }

    // 定义一个用于处理消息的Actor
    static class MessageHandler {
        public static Behavior<Message> create() {
            return Behaviors.receive(Message.class)
                    .onMessage(Message.class, (context, message) -> {
                        // 处理消息
                        System.out.println("Received message: " + message.getContent());
                        return Behaviors.same();
                    })
                    .build();
        }
    }

    // 定义一个MessageAdapter，将消息转发给MessageHandler进行处理
    static class MessageAdapter {
        public static Behavior<Message> create(ActorRef<Message> target) {
            return Behaviors.receive(Message.class)
                    .onMessage(Message.class, (context, message) -> {
                        // 转发消息给目标Actor
                        target.tell(message);
                        return Behaviors.same();
                    })
                    .build();
        }
    }

    @Test
    public void testMessageAdapter() {
        // 创建ActorSystem
        ActorSystem<Void> system = ActorSystem.create(Behaviors.empty(), "testSystem");

        // 创建MessageHandler
        Behavior<Message> messageHandlerBehavior = MessageHandler.create();
        ActorRef<Message> messageHandler = system.systemActorOf(messageHandlerBehavior, "messageHandler");

        // 创建MessageAdapter，并将消息转发给MessageHandler
        Behavior<Message> messageAdapterBehavior = MessageAdapter.create(messageHandler);
        BehaviorTestKit<Message> testKit = BehaviorTestKit.create(messageAdapterBehavior);

        // 发送消息给MessageAdapter
        Message message = new Message("Hello");
        testKit.run(message);

        // 验证MessageHandler是否收到了消息
        assertEquals(1, testKit.expectEffect().messageEffects().size());
        assertEquals(message, testKit.expectEffect().messageEffects().get(0).message());
    }
}