1

私は ActiveMQ をメッセージ ブローカーとして使用しており、Qpid proton c ライブラリを使用してメッセージング サービス用の 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().

上記の erlang で行ったのと同じように、ActiveMQ ブローカーに接続するモジュールを elixir で作成する必要があります。ただし、Erlang は qpid ライブラリを使用してメッセージ ブローカー サービスに接続されています。提案してください。

4

1 に答える 1