Hi!
I'm giving my firsts steps with Akka, I'm mainly a Java developer and i
have been quite interested in this framework.
The issue I'm facing is the following:
I have one very simple app as server :
public class BackendApp {
private static ActorSystem backend;
public static void main(String[] args) {
Config config = ConfigFactory.load();
backend = ActorSystem.create("backend",
config.getConfig("backend").withFallback(ConfigFactory.load()));
backend.actorOf(Props.create(Simple.class), "simple");
}
}
where Simple Actor is
public class Simple extends UntypedActor {
public Simple(){
}
@Override
public void onReceive(Object message) {
System.out.println(message);
System.out.println(this.getSender());
if(message.equals("terminate")){
System.out.println("Backend App terminating");
this.getContext().system().terminate();
}else{
unhandled(message);
}
}
}
and a client:
public class ClientApp {
private static ActorSystem frontEnd;
public static void main(String[] args) {
Config config = ConfigFactory.load();
frontEnd = ActorSystem.create("client",
config.getConfig("client").withFallback(ConfigFactory.load()));
String path = "akka.tcp://[email protected]:2551/user/simple";
ActorSelection simple = frontEnd.actorSelection(path);
simple.tell("Hello", ActorRef.noSender());
simple.tell("terminate", ActorRef.noSender());
System.out.println("Client App terminating");
frontEnd.terminate();
}
}
and the config file application.conf is this:
backend {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1"
port = 2551
}
}
}
client {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "127.0.0.1"
port = 2552
}
}
}
that's all.
The problem is that the client actor selection seems to be looking for the
remote actor in the "client" system ignoring the remote reference.
And I have also seen that:
backend.provider() is akka.actor.LocalActorRefProvider
and not the configured remote one in the conf file.
When the client wants to send a message to the backend this is the error
message displayed:
[client-akka.actor.default-dispatcher-2] [akka://client/deadLetters]
Message [java.lang.String] from Actor[akka://client/deadLetters] to
Actor[akka://client/deadLetters] was not delivered. [1] dead letters
encountered.
So I would say no remoting configuration is being considered at all.
I have been reading the documentation but it seems I'm missing something.
I am running this apps from eclipse by just right clicking on each of
the main class files and running them as applications, no extra params
supplied.
Could someone enlight me a bit please?
thanks a lot.
Fede
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
