Реализация обработчиком событий GenServer, не обрабатывающим приведение - PullRequest
Новая
       41

Реализация обработчиком событий GenServer, не обрабатывающим приведение

1 голос
/ 26 июня 2019

Я пытаюсь использовать GenServer в качестве обработчика событий для EventBus в моем приложении Phoenix, но по какой-то причине я не могу понять, почему ручкаФункция приведения не вызывается.Я проверил, что процесс был активен с :observer.start().

Есть ли что-то, чего мне не хватает, чтобы GenServer правильно обрабатывал вызов приведения?

По сути, функция процесса должнаобработать входящее событие и привести его к GenServer, где GenServer будет обрабатывать приведение и выполнять доменную логику для этого события.

---- серверный модуль Gen ---- 

defmodule App.Notifications.EventHandler do
  use GenServer
  require Logger


  def start_link(opts \\ []) do
    {:ok, pid} = GenServer.start_link(__MODULE__, [], opts)
  end

  def init([]) do
    {:ok, []}
  end

  def process({topic_id, event_id}) do
    Logger.info("event notification process recieved!!") <---- THIS IS GETTING PRINTED!

    GenServer.cast(__MODULE__, {topic_id, event_id})
  end



def handle_cast({topic_id, event_id}, state) do
  Logger.info("event  notification data Recieved!!") <----- THIS IS NOT

  # do stuff

  {:noreply, state}
end


end

---- Модуль приложения ----- 

defmodule App.Application do
  # See https://hexdocs.pm/elixir/Application.html
  # for more information on OTP Applications
  @moduledoc false

  use Application


  def start(_type, _args) do

    EventBus.subscribe({App.Notifications.EventHandler, ["^event_notification_created$"]})

    # List all child processes to be supervised
    children = [
      # Start the Ecto repository
      App.Repo,
      # Start the endpoint when the application starts
      AppWeb.Endpoint,
      # Starts a worker by calling: App.Worker.start_link(arg)
      # {App.Worker, arg},,
      App.Notifications.EventHandler <--- STARTING THE GEN SERVER HERE
    ]

    # See https://hexdocs.pm/elixir/Supervisor.html
    # for other strategies and supported options
    opts = [strategy: :one_for_one, name: App.Supervisor]
    Supervisor.start_link(children, opts)
  end

  # Tell Phoenix to update the endpoint configuration
  # whenever the application is updated.
  def config_change(changed, _new, removed) do
    App.Endpoint.config_change(changed, removed)
    :ok
  end
end

1 Ответ

1 голос
/ 26 июня 2019

Документация по GenServer.cast/2 гласит, что первый параметр в вызове GenServer.cast/2 должен иметь тип server(), который:

любое из значений, описанных в разделе « Регистрация имени » документации для этого модуля.

В вашем коде вы запускаете ссылку без имени: 

GenServer.start_link(__MODULE__, [], opts)

но затем вы разыгрываете на имя GenServer: 

#              ⇓⇓⇓⇓⇓⇓⇓⇓⇓⇓
GenServer.cast(__MODULE__, {topic_id, event_id})

Самый простой способ это исправить - запустить сервер с именем: 

GenServer.start_link(__MODULE__, [], name: __MODULE__)
...