1

パブリッシャーは正常に作成されましたが、以下を使用してサブスクライバーを作成できませんでした:

    public static void main(String [] args)
    {
        ActorSystem system = ActorSystem.create("System");
        ActorRef subscriber = system.actorOf(new Props(Sub.class),   "subscriber");    
        subscriber.tell(new MyActor("CharlieParker", 50, 25), subscriber);
    }
    public class Sub extends UntypedActor 
    {
        ActorRef subSocket = ZeroMQExtension.get(getContext().system()).newSubSocket(
        new Connect("tcp://127.0.0.1:1237"),
        new Listener(getSelf()), Subscribe.all());
    }

次のエラーが発生しました: ActorSystem[System] java.lang.NoSuchMethodError に対して 'akka.jvm-exit-on-fatal-error' が有効になっているため、スレッド [System-akka.zeromq.socket-dispatcher-7] が JVM をシャットダウンしています。 : org.zeromq.ZMQ$Poller.poll(J)J at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala:180) at akka.zeromq.ConcurrentSocketActor$$anonfun$10.apply(ConcurrentSocketActor.scala: 179) akka.zeromq.ConcurrentSocketActor.akka$zeromq$ConcurrentSocketActor$$doPoll(ConcurrentSocketActor.scala:197) で akka.zeromq.ConcurrentSocketActor$$anonfun$receive$1.applyOrElse(ConcurrentSocketActor.scala:46) で akka.actor. akka.actor.ActorCell.invoke(ActorCell.scala:386) で ActorCell.receiveMessage(ActorCell.scala:425) akka.dispatch.Mailbox.processMailbox(Mailbox.scala:230) で akka.dispatch.Mailbox.run(Mailbox.scala:212) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread .run(Thread.java:722)

どういう意味ですか？

4

2 に答える 2

0

パスに zeromq-scala-binding がないか、間違ったバージョンがあるようです。

どのバージョンの akka と zeromq を使用していますか?

于 2013-04-30T10:57:10.043 に答える