hi guys! I am again stuck with a cluster pub sub problem. Recently, I was using the *Send()* method of *DistributedPubSubMediator *but seems like the message are not being received by the subscriber.
Instead of subscribe, I have used put in the subscriber actor initialization : mediator.tell(new DistributedPubSubMediator.Put(getSelf()), getSelf()); I am creating crating the subscriber actor as a router: system.actorOf(Props.create(*SubscriberActor*.class).withRouter(new > FromConfig()), "*subscriberActor*"); and I am sending messages to the subscriber actor through the DistributedPubSubMediator from the publisher actor : Future<Object> someFuture = ask(mediator, new > DistributedPubSubMediator.Send(*"/user/subscriberActor"*, someMessage > ,true), timeout); The above strategy works with *Publish() *but can't get it working with* Send()*. Am I missing something? Please suggest. Kind regards, Amit -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: http://akka.io/faq/ >>>>>>>>>> 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/groups/opt_out.
