java - 通过 Java API 使用 Akka AbstractActorWithTimers

Question

我正在尝试在 Java(好吧，Groovy，真的)应用程序中使用新的 Akka Timers API，当然使用 Akka/Java API(我使用的 Gradle 坐标是 'com.typesafe. akka:akka-actor_2.11:2.5.4')。当我尝试创建新的带有计时器的 actor 时，出现编译器错误:

class MyTimeAwareActor extends AbstractActorWithTimers {
    @Override
    void onReceive(Object message) {
        if(message in StartNewTimer) {
            timers.startPeriodicTimer(/* blah whatever */)
        }
    }
}

此代码在使用 @Override 注释时产生编译器错误:

"Groovy:Method 'onReceive' from class com.example.myapp.MyTimeAwareActor does not override method from its superclass or interfaces but is annotated with @Override."

这告诉我我错误地使用了这个 Actor 。我想做的就是每次 Actor 收到 StartNewTimer 消息时启动一个新的计时器(执行某些操作)。

有什么想法可以做到这一点并修复此编译器错误吗？

Answer 1

将 onReceive 替换为 createReceive (以下是 Java 语言；您可以将其转换为 Groovy):

@Override
public Receive createReceive() {
    return receiveBuilder()
        .match(StartNewTimer.class, message -> {
            getTimers().startPeriodicTimer(/* blah whatever */);
        })
        .build();
}

onReceive 未在 AbstractActorWithTimers 或其父级 AbstractActor 中定义(onReceive 在 UntypedAbstractActor)。