У меня есть компонент приложения, Processor.java
, который прослушивает события из внешнего источника. Я хочу использовать актеров для передачи этих событий в сокет. У меня есть класс субъектов, обрабатывать эти события:Инициализация актера в Akka, Play 2.4.2
public class EventProcessor extends UntypedActor {
static ActorRef channel = Akka.system().actorOf(Props.create(EventProcessor.class));
public void onReceive(Object message) throws Exception {
// do stuff here
}
public void handleMessage(String event) {
// tell another actor to do stuff here
}
}
Я хочу, чтобы иметь возможность создать экземпляр актеров типа EventProcessor
в Process.java
. Прямо сейчас, у меня есть это:
ActorRef act = Akka.system().actorOf(new Props(EventProcessor.class), null);
act.handleMessage(str);
Я получаю ошибку компиляции:
constructor Props in class akka.actor.Props cannot be applied to given types;
required: akka.actor.Deploy,java.lang.Class<?>,scala.collection.immutable.Seq<java.lang.Object>
found: java.lang.Class<models.EventProcessor>
reason: actual and formal argument lists differ in length
Что такое правильный способ создать экземпляр актера в Акку в моем случае?