On Tue, Jul 21, 2015 at 10:56 PM, Richard Rodseth <[email protected]> wrote:
> I'd love a little more input on this, being a complete neophyte when it > comes to Akka cluster. > > To recap, let's call this entity ChannelMonitor. There are many many > ChannelMonitors underneath a ChannelMonitorSupervisor. > Currently, a message pertaining to a particular channel gets from the > supervisor to the appropriate ChannelMonitors by being placed on an > eventbus with LookupClassification. Each ChannelMonitor subscribes to this > event bus. > > It seems to me that one appoach to clustering would be to shard the > supervisors - i.e have several ChannelMonitorSupervisors per node/shard > region, and retain the event-bus-based distribution to the ChannelMonitor > children. > This sounds good to me if each message only has one ChannelMonitorSupervisor destination. > > Another would be to broadcast to all the ChannelMonitors and have them > ignore messages for other channels, but that seems a bit hokey > > Another would be DistributedPubSub with a topic per channel, but since > there is an open-ended number of channels, that doesn't feel right either. > > The ChannelMonitors are really the thing that there are lots of, and would > correspond to a DDD aggregate root (I believe), and would be a persistent > actor if I were using Akka persistence. > > Should I be considering DistributedPubSub with sendOneMessageToEachGroup > and a custom routing logic? > > Thanks for any thoughts on this use case. > > > > > > On Fri, Jul 10, 2015 at 9:11 AM, Richard Rodseth <[email protected]> > wrote: > >> But I'll take a look, thanks. Not sure if one topic per channel is >> feasible. >> >> On Fri, Jul 10, 2015 at 9:04 AM, Richard Rodseth <[email protected]> >> wrote: >> >>> Nope. I imagined it to be for broadcasting, rather than having something >>> analagous to LookupClassification. >>> >>> On Fri, Jul 10, 2015 at 12:16 AM, Jim Hazen <[email protected]> >>> wrote: >>> >>>> Tried looking at the DistributedPubSub module? >>>> >>>> -- >>>> >>>>>>>>>> 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 http://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 [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/d/optout. > -- Patrik Nordwall Typesafe <http://typesafe.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 [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/d/optout.
