Akka Scala演员必须扩展akka.actor.Actor
Akka Java actor必须扩展akka.actor.UntypedActor
因此,在使用非默认构造函数定义Scala actor并从Java代码创建它时,我遇到了以下问题:
ActorRef myActor = system.actorOf(new Props(new UntypedActorFactory() {
public UntypedActor create() {
return new MyActor("...");
}
}), "myactor");
当然,UntypedActorFactory期望创建UntypedActor类型的对象,但是我的actor是Actor类型。
解决方法是什么?
编辑:
按照Viktor的说明使用akka.japi.Creator,此方法有效:
Props props1 = new Props();
Props props2 = props1.withCreator(new akka.japi.Creator() {
public Actor create() {
return new MyActor("...");
}
});
ActorRef actorRef = Main.appClient().actorOf(props2, "myactor");
参考方案
在这种情况下,传递akka.japi.Creator而不是UntypedActorFactory。
另外,至少在2.0.1及更高版本中,它不需要UntypedActor:
trait UntypedActorFactory extends Creator[Actor] with Serializable
https://github.com/akka/akka/blob/v2.0.1/akka-actor/src/main/scala/akka/actor/UntypedActor.scala#L161
使用Alpakka连接器的多个使用者线程 - java我正在使用Alpakka kafka连接器来消耗来自kafka的数据包。我正在使用Consumer作为CommittableSource。我想在一台计算机上创建多个使用者线程,并将它们用作单个源。我该如何实现?当前,我已经使用Consumer.CommittableSource创建了多个源,并使用“合并”功能将所有源合并为一个源。但是我不确定这是否是正确的方…
Java:线程池如何将线程映射到可运行对象 - java试图绕过Java并发问题,并且很难理解线程池,线程以及它们正在执行的可运行“任务”之间的关系。如果我创建一个有10个线程的线程池,那么我是否必须将相同的任务传递给池中的每个线程,或者池化的线程实际上只是与任务无关的“工人无人机”可用于执行任何任务?无论哪种方式,Executor / ExecutorService如何将正确的任务分配给正确的线程? 参考方案 …
JAVA:字节码和二进制有什么区别? - javajava字节代码(已编译的语言,也称为目标代码)与机器代码(当前计算机的本机代码)之间有什么区别?我读过一些书,他们将字节码称为二进制指令,但我不知道为什么。 参考方案 字节码是独立于平台的,在Windows中运行的编译器编译的字节码仍将在linux / unix / mac中运行。机器代码是特定于平台的,如果在Windows x86中编译,则它将仅在Win…
Scala-运行时字符串模板 - java我想做的正是java的String模板,但是在scala中。但是,该库不适用于案例类:case class Obj(str:String) val st = new ST("xx $obj.str$ xx",'$','$') st.add("obj",Obj("repl…
java:继承 - java有哪些替代继承的方法? java大神给出的解决方案 有效的Java:偏重于继承而不是继承。 (这实际上也来自“四人帮”)。他提出的理由是,如果扩展类未明确设计为继承,则继承会引起很多不正常的副作用。例如,对super.someMethod()的任何调用都可以引导您通过未知代码的意外路径。取而代之的是,持有对本来应该扩展的类的引用,然后委托给它。这是与Eric…