PubSub Put not working? Documentation coding examples wrong?
#23.500 aberto em 9 de ago. de 2017
Métricas do repositório
- Stars
- (13.277 estrelas)
- Métricas de merge de PR
- (Mesclagem média 8d 19h) (10 fundiu PRs em 30d)
Description
Hi Guys!
I tried to implement Distributed Send PubSub's use case with Akka 2.4.14 and I couldn't get it to work across nodes.
The Destination Put's call never got a SubscribeAck (not sure if it should but in the documentation's code it leads you to believe so)
Also, perhaps related: I noticed that the code examples where copy pasted from the topics above and perhaps led to errors: like these lines:
//somewhere else
ActorRef sender = system.actorOf(Props.create(Publisher.class), "sender");
// after a while the destinations are replicated
sender.tell("hello", null);
As we made a Destination and a Sender class, the creation of a Publisher looks out of place.
So, is the DistributedPubSubMediator.Put call supposed to work across nodes on the same cluster?
I eventually ended up doing a Publish with groups and sendOneMessageToEachGroup=true for the same effect.
But I wasn't the only one with that problem as I found this StackOverflow thread:
Are the docs wrong? is the Put supposed to work across the cluster? did the 2.4.14 version (that was the one shipped with Play 2.5.X) have a bug?
Cheers