私のテスト用の rabbitmq 環境には、キュー D4 があります。
トピック交換を使用して、メッセージを D4 キューに発行したいと考えています。
Web 管理コンソールで、ルーティング キー K を持つメッセージをキュー D4 にバインドしました。
しかし、私のメッセージは D4 キューに配信されません。
トピックを直接交換に変更すると、すべて問題ありません。
コードの何が問題になっていますか?
ExchangeName = <<"custom.topic">>,
ExchangeType = <<"topic">>,
Key = <<"K">>,
Msg = <<"123">>,
{ok, Connection} = amqp_connection:start
(#amqp_params_network{username = <<"guest">>, password = <<"guest">>, host = "192.168.1.1"}),
{ok, Channel} = amqp_connection:open_channel(Connection),
#'exchange.declare_ok'{} =
amqp_channel:call(Channel, #'exchange.declare'{exchange=ExchangeName, durable=true, type = ExchangeType}),
amqp_channel:call(Channel, #'basic.publish'{routing_key = Key}, #amqp_msg{props = #'P_basic'{delivery_mode=2}, payload = Msg}),