Акка будущее с Play Framework

Question

Я пытаюсь использовать будущее Akka с Play Framework для подключения к удаленной системе Akka ОтказПосле запуска системы Akka Future дает мне предупреждение о том, что один аргумент оставлен.

Код ниже:

Это код [Код контроллера LAY: P

ackage controllers;

import com.typesafe.config.ConfigFactory;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import play.*;
import play.mvc.*;

import views.html.*;

public class Application extends Controller {



  public static Result index() throws InterruptedException { 

      System.out.println(" Local Node Called0");


      ActorSystem csystem = ActorSystem.create("Application", ConfigFactory.load().getConfig("LocalNode"));
      ActorRef localNode = csystem.actorOf(new Props(LocalNode.class));

        System.out.println(" Local Node Called1");
        localNode.tell("Hello");
        System.out.println(" Local Node Called2");

        Thread.sleep(5000);
        csystem.shutdown();
        return ok(index.render("I am OK"));
  }           
}

.

Это игра Play Framework Local Actor Uode

контроллеры пакета;

Импорт Akka.actor. ; Импорт Akka.dispatch.await; Импорт Akka.dispatch.future; Импорт Akka.event.logging; Импорт Akka.event.loggingAppter; Импорт Akka.Util.duration; Импорт Akka.util.Timeout; Импорт Akka.pattern. ;

Пунктарный класс Localnode расширяет Untyperdactor {

    LoggingAdapter log = Logging.getLogger(getContext().system(), this);
    Timeout timeout = new Timeout(Duration.parse("20 seconds"));

    ActorRef masterActor;

    public void preStart()
    {
        /* Get reference to Master Node*/
         masterActor = 

    getContext().actorFor("akka://MasterNode@127.0.0.1:2552/user/masterActor");
    }

    @Override
    public void onReceive(Object message) throws Exception {
        System.out.println(" Future called  ");

         Future<Object> future = Patterns.ask(masterActor , message.toString(), timeout);

            String result = (String) Await.result(future, timeout.duration());

            log.info("Messagefrom Server", result.toString());  
    }
   }

.

Это удаленный мастер систем Akka Nide

package Rubine_Cluster;

import com.typesafe.config.ConfigFactory;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.UntypedActor;
import akka.kernel.Bootable;

/**
 * Hello world!
 *
 */
public class MasterNode implements Bootable
{
     final ActorSystem system;

      public MasterNode() {
        system = ActorSystem.create("MasterNode", ConfigFactory.load()
            .getConfig("masterNode"));
        ActorRef masterActor = system.actorOf(new Props(MasterActor.class),"masterActor");
        System.out.println(" Master Node is called ");
      }

      public void startup() {

      }

          public void shutdown() {
            system.shutdown();
          }
}  

.

Это Masteractor удаленной системой Akka

package Rubine_Cluster;

import akka.actor.*;


public class MasterActor extends UntypedActor {

    @Override
    public void onReceive(Object message) throws Exception {


         if (message instanceof String) {
                // Get reference to the message sender and reply back
                getSender().tell(message + " got something");       
    }
  }  
}

.

Это сообщение от Play FrameWrok

[INFO] [09/30/2012 16:47:25.669] [Application-akka.actor.default-dispatcher-1] [
akka://Application/user/$a] Messagefrom Server WARNING arguments left: 1

.

Помощь нужна, потому что я должен соответствовать сроку назначения

Благодаря всем

Answer 1

Попробуйте дать имя вашего актера в Play:

ActorRef localNode = csystem.actorOf(new Props(LocalNode.class), "localNode");

.

А также обратите внимание, что если вам нужно получить доступ к системе Akka от игры, лучше использовать:

ActorSystem csystem = Akka.system();

.

вместо:

ActorSystem csystem = ActorSystem.create("Application", ConfigFactory.load().getConfig("LocalNode"));

.

Answer 2

«Аргументы оставили: 1» Предупреждение обусловлено следующей строкой:

log.info("Messagefrom Server", result.toString())

.

Вы проходите неиспользованные слова к регистратеру.Это должно быть это вместо этого:

log.info("Messagefrom Server {}", result.toString())

.