如何限制发送到Akka中IO(Tcp)执行元的消息

akka {
  io {
    tcp {
      batch-read-limit = 10
      max-received-message-size = 1MB
      write-ack-timeout = 5s
    }
  }
}

import akka.actor.ActorSystem;
import akka.io.Inet;
import akka.io.Tcp;
import akka.io.TcpMessage;
import akka.actor.AbstractActor;
import akka.actor.Props;

public class MyActor extends AbstractActor {
  private final ActorRef tcpManager = Tcp.get(getContext().getSystem()).getManager();
  
  @Override
  public Receive createReceive() {
    return receiveBuilder()
      .matchEquals("start", s -> {
        InetSocketAddress remoteAddress = new InetSocketAddress("127.0.0.1", 8080);
        ActorRef tcp = Tcp.get(getContext().getSystem()).getManager();
        Tcp.Command connect = TcpMessage.connect(remoteAddress, null, null, null);
        tcp.tell(connect, getSelf());
      })
      .match(Tcp.Connected.class, conn -> {
        // 处理连接成功的逻辑
      })
      .build();
  }
  
  public static Props props() {
    return Props.create(MyActor.class);
  }
}

ActorSystem system = ActorSystem.create("MySystem");
ActorRef myActor = system.actorOf(MyActor.props(), "myActor");
myActor.tell("start", ActorRef.noSender());