2

我创建了一个小型 genserver 应用程序，引用 Elixir 的 Etudes 并且运行良好，当我启动服务器并执行 GenServer.call..我得到所需的数据。

同时，我的应用程序也在接收来自其他生产者的消息，这些消息必须被捕获，因为现在只要我的应用程序收到如下任何消息，它就可以在 shell 上看到。

iex(6)> subscription 0x7fdc83c0cdf0 ref 0x7fdc8403fc00
encode_message num 2
encode_message address topic://tryme
next/type PN_STRING
encode_message body alloc size 8192
encode_message formatted body "message body..."
write message sz: 130
Msg {message,#Ref<0.0.0.753>,
          #{address => "topic://tryme",
            body => "Enter some text here for the message body..."}}
AMQP Message received {message,#Ref<0.0.0.753>,
                            #{address => "topic://tryme",
                              body => "message body..."}}

如何在我的应用回调函数中获取此消息以进一步发送到数据库。据我所知，我会在我的 handle_info 中收到这条消息，因为消息不是使用 GenServer.call 调用的。但不确定如何。

4

1 回答 1

4

如果您的 GenServer 正在接收来自另一个进程的消息，那么您应该能够简单地在 handle_info/2 中匹配它们。尝试这样的事情：

def handle_info(msg, state) do
  IO.inspect {:handle_info, msg}
  {:noreply, state}
end

但是，如果添加此行后没有打印任何内容，则表示您没有收到您期望的消息。

于 2014-07-17T08:28:57.457 回答