To make a difference it should be filtered on the sending side and that would complicate the model quite a lot as far as I can see. Currently there is only a notion of a topic represented by one ActorRef per node, independent of how many local subscribers there are.
/Patrik On Mon, Jun 26, 2017 at 4:20 PM, Gajendra Naidu <gajendra.na...@gmail.com> wrote: > Patrik > > Was there any technical reason why it is not supported? if no, I can > contribute to add this functionality. > > Gajendra > > On Thursday, June 22, 2017 at 10:27:40 PM UTC+5:30, Patrik Nordwall wrote: >> >> That is not supported. You have to filter in the destination (or put >> another actor in-between). >> /Patrik >> tors 22 juni 2017 kl. 08:44 skrev Gajendra Naidu <gajendr...@gmail.com>: >> >>> Just wondering if there is a way in AKKA - DistributedPubSub to >>> subscribe messages with some filter like take the function as a parameter. >>> The function should be like f(x) => boolean and send the message if the >>> function returns true. >>> >>> mediator ? DistributedPubSubMediator.Subscribe(subscription, ( x => >>> true), self) >>> >>> This way message queuing to the subscriber can be avoided. >>> >>> Gajendra >>> >>> -- >>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>> >>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/c >>> urrent/additional/faq.html >>> >>>>>>>>>> Search the archives: https://groups.google.com/grou >>> p/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+...@googlegroups.com. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at https://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> -- > >>>>>>>>>> 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. > -- Patrik Nordwall Akka Tech Lead Lightbend <http://www.lightbend.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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.
