Pubsub system, where I know more about the subscribers

I will not comment on your bigger goal but :pg2 got replaced by :pg – so you could check that out.

I’m pretty sure you could just use Phoenix.PubSub out of the box. Perusing the pg2 adapter module, it does check for :pg first.

Just generally speaking you could do something like:

Phoenix.PubSub.subscribe(MyApp.PubSub, "user")
Phoenix.PubSub.broadcast(MyApp.PubSub, "user", :welcome_message)

Phoenix.Tracker.list(MyApp.PubSub, "user")

I found this book by @sb8244 really helpful.

Oh, interessting. I have seen :pg. But bebause it is kind of unintuitive, that :pg replaced :pg2 and not the other way around, I did not think of it.
Thanks for the hint!

Thanks for the advice! The book looks very interesting, I will put it on my reading list.
The Phoenix Tracker list function I was also not aware of, that is very useful to me.

But I am also a little confused. In your example, the :welcome_message would get send to any subscriber whenever any new subscriber arrives, right?
Just checking,if I understand correctly.

But I could just write an explicit subscribe function and send an initial message to the process that just subscribed.

Thanks for the help!.

Yes in that example it would get sent to everyone.

The convention is to have topics delimited by a colon.

So you could subscribe the user, roadrunner, to “user:acme:roadrunner” to track users by company, so you could broadcast a message to all users, all users working at acme or just roadrunner.

You could use pg:monitor_scope or pg:monitor.
Then you get a message whenever a process leaves or joins.
pg is very flexible, you can have multiple scopes, group names can be any term.