Might be good in a new thread, but what issue were you having with pg2 calls? You should be able to call them straight as normal?
OvermindDL1
greentornado
I currently using raw cowboy websocket but dont know how to intergrate pg2 into the app and make a cluster 
0
kokolegorille
You can use Phoenix.PubSub directly (without Phoenix). By default it uses pg2.
There was the Firenest project, but development has been halted and incorporated into Phoenix.PubSub.
Otherwise there are also libcluster, and swarn, to help You for distribution.
BTW Phoenix channels are using pg2 pubsub mecanism under the hood.
0
greentornado
Thanks
I took a look at https://github.com/phoenixframework/phoenix_pubsub
So where do I put this kind of Phoenix.PubSub.subscribe(MyApp.PubSub, "user:123") into ? Maybe my ws handler for each connection ?
0
kokolegorille
greentornado
In this init or websocket_init block should I ?
def init(request, _state) do
state = %{registry_key: request.path}
opts = %{idle_timeout: 900_000}
{:cowboy_websocket, request, state, opts}
end
def websocket_init(state) do
{:ok, state}
end
0
kokolegorille
greentornado
So I guess the Phoenix.PubSub.subscribe function will subcribe the pid of the websocket with the topic user:123 right ?
0
kokolegorille