Hi,
I'm working with Akka 2.3.0, constructing a 2 nodes cluster with this
configuration on both nodes:
actor {
provider = "akka.cluster.ClusterActorRefProvider"
extensions = ["akka.contrib.pattern.ClusterReceptionistExtension"]
}
remote {
log-remote-lifecycle-events = off
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "172.18.21.55"
# hostname = "127.0.0.1"
port = 2551
}
}
cluster {
seed-nodes = [
"akka.tcp://[email protected]:2551","akka.tcp://[email protected]:2551"
]
# "akka.tcp://[email protected]:2551"]
#,"akka.tcp://[email protected]:2552"]
min-nr-of-members = 2
auto-down-unreachable-after=10s
}
.
on the start of each system, I run the folowing code to register
the Receptionist on each system:
// Create device manager actor
ActorRef deviceManagerActor =
system.actorOf(Props.create(ChannelManagerActor.class, deviceManager),
"device-manager");
// Register service for cluster clients
ClusterReceptionistExtension.get(system).registerService(deviceManagerActor);
and I have a Play framework system, running on a seperate machine, trying
to send messages to the "device-manager", but every single one of the
messages is being sent to the same node without being randomly selected on
the *Send()* request. as being documented that is should. I thought that it
would randomly pick on each message the device-manager of either one of my
nodes.
what am I doing wrong?
attaching the client code and the properties assigned to the code:
additionalConfig.akka.channelManager =
"akka.tcp://[email protected]:2551/user/receptionist,akka.tcp://[email protected]:2551/user/receptionist"
additionalConfig.akka.targetActor = "/user/device-manager"
*remoteReceptionists *= new HashSet<ActorSelection>();
String[] managers =
Play.application().configuration().getString("additionalConfig.akka.channelManager").split(",");
//Go over each manager configured in .conf file and add to
for (String manager : managers) {
remoteReceptionists.add(Akka.system().actorSelection(manager));
}
public static ActorRef *getClient()* {
if (ChannelManagerActorHolder.client == null) {
ChannelManagerActorHolder.client =
Akka.system().actorOf(ClusterClient.props(*remoteReceptionists*,
timeout.duration(), timeout.duration()));
//Thread.sleep(5000);
}
return ChannelManagerActorHolder.client;
}
and the send itsef:
ChannelManagerActorHolder.*getClient()*.tell(
new
ClusterClient.Send(Play.application().configuration().getString("additionalConfig.akka.targetActor"),
msg, true),
ChannelManagerActorHolder.getClient());
Sorry for the mess, hopes it make sense.
Thank allot in advance
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
