amqp - 使用 Elixir 到 Active MQ 的 AMQP 连接字符串

Question

我正在使用 ActiveMQ 作为消息代理，并使用 Qpid proton c 库连接到 Erlang 以进行消息传递服务，并且在运行 ActiveMQ 的情况下似乎可以很好地使用以下命令。

qpidpn:subscribe("amqp://127.0.0.1/topic://destination").
qpidpn:publish(#{address => "amqp://127.0.0.1/topic://destination", body => "hello"}).
flush().
qpidpn:stop().
q().

我需要在 elixir 中编写一个模块来连接到 ActiveMQ 代理，就像上面在 erlang 中所做的一样。Erlang 虽然使用 qpid 库连接到消息代理服务。请建议。

Answer 1

我还没有尝试过下面的代码，但是从 Elixir 调用 Erlang 库非常简单。

尝试这个：

:qpidpn.subscribe("amqp://127.0.0.1/topic://destination")
:qpidpn.publish(%{:address => "amqp://127.0.0.1/topic://destination", :body => "hello"})
:flush()
:qpidpn.stop()
:q()

正如我所说，我没有尝试过（也不能因为我没有安装 amqp 或 qpidn），但这可能与您正在寻找的内容一致。