What about a hybrid approach?
- Keep the sourcing as-is
- Use a centralized collection of processes that do
Postgrex.Notifications.listenand then push notifications to PubSub - Listeners subscribe to PubSub
This could also make a smooth transition easier; once the pool of listeners is in place, individual listeners can be switched over to PubSub one at a time.
