使用 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，所以我没有尝试过），但这可能符合您的要求。