Hi again.
If the use-case is not clear I could prepare a code-sample to clarify the
point.
Thanks again for any help.
El domingo, 29 de octubre de 2017, 21:26:25 (UTC+1), Eduardo Fernandes
escribió:
>
> 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 [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.
