Hi all. I had this working with java version 2.3.13 and after moving to
2.5.6 it stop working. Let me explain the topology.
In configuration I have
akka.cluster.sharding {
role = "backend"
}
Ok then. If in a process (frontend) I use startProxy and in other process
(backend) I use start in ClusterSharding everything looks ok. My problems
start with I have a more than one ShardRegion in the game:
1) client: starts two proxies for shards (A and B)
2) one server start A and get proxy for B
3) other server starts B and proxy to A
What I'm observing is that the client talks to A via proxy. The actor in
server receives the request but when tries to send a copy to the other
server using the corresponding proxy to B it never reaches the other server.
I'm observing this in the log:
[29/10/17 21:18:55:996 CET] WARN sharding.ShardRegion: Trying to register
to coordinator at
[Some(ActorSelection[Anchor(akka://object-server-cluster/),
Path(/system/sharding/processor-actor-1Coordinator/singleton/coordinator)])],
but no acknowledgement. Total [475] buffered messages.
My code to create the shard regions:
if (isLocal) {
ClusterSharding.get(clusterSystem).start(shardingName,
Props.create(ProcessorActor.class, this), settings, new MessageExtractor(),
allocationStrategy,
PoisonPill.getInstance());
} else {
Optional<String> role = Optional.of(CLUSTER_ROLE_BACKEND);
ClusterSharding.get(clusterSystem).startProxy(shardingName,
role, new MessageExtractor());
}
and isLocal is true for region A in server 1 and for region B in server 2,
and false of the other shard region in each server, as you can imagine.
Maybe this kind of user case is not supported in 2.5.6 anymore? I'm pretty
sure that is not the case but I can't find the right way to instance the
shads.
Many thanks in advance for any help on this.
Regards.
/Eduardo
--
>>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
