非类型化的参与者（Java+Akka):重新处理未处理的消息

Question

我正在创建一个使用Java+阿卡的演员系统。特别是，我通过提供onReceive（）方法的实现来定义非类型化的参与者。

在该方法中，我通过定义接收消息时要执行的逻辑来实现参与者的行为。它可能是：

public void onReceive(Object msg) throws Exception {
  if(msg instanceof MsgType1){ ... }
  else if(msg instanceof MsgType2){ ... }
  else unhandled(msg);
}

但是，如果演员只对单一类型的味精感兴趣呢？有没有可能实现选择性接收，使参与者等待某个消息（系统自动重新排队所有其他类型的消息）？？？

Answer 1

在Akka Afaik中无法使用这种“A la Erlang”消息处理模式。但是，你可以使用Stash来获得你想要的效果。

因此代码看起来如下所示

public void onReceive(Object msg) throws Exception {
    if(msg instanceof MsgType1){ ... }
    else if(msg instanceof MsgType2){ ... }
    else stash();
}

在消息处理的某个时刻，您将切换到另一个状态（可能通过调用getContext().benge)。您还可以执行unstashall()调用，以便将在此之前忽略的消息重新追加回邮箱。