Event Notification in Phoenix with PubSub

event_notification.ex

defmodule MyApp.Subscriber do
  use GenServer

  def start_link(channel) do
    GenServer.start_link(__MODULE__, channel)
  end

  def init(channel) do
    pid = self
    ref = MyApp.Endpoint.subscribe(pid, channel)
    {:ok, {pid, channel, ref}}
  end

  def handle_info(%{event: "test"} = message, state) do
    IO.inspect "#######################"
    IO.inspect "Test - Received Message:"
    IO.inspect message
    IO.inspect "#######################"
    {:noreply, state}
  end

  def handle_info(message, state) do
    IO.inspect "#######################"
    IO.inspect "Catch All - Received Message:"
    IO.inspect message
    IO.inspect "#######################"
    {:noreply, state}
  end
end

# MyApp module

worker(MusicAccent.Subscriber, ["events:all"])

# IEx

MyApp.Endpoint.broadcast!("events:all", "test", %{foo: "bar"})