0

私のテスト用の 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}),
4

1 に答える 1

0

私は自分でエラーを見つけました。

amqp_channel:call(Channel, #'basic.publish'{ exchange= ExchangeName ,routing_key = Key}, #amqp_msg{props = #'P_basic'{delivery_mode=2}, ペイロード = メッセージ})

于 2012-08-28T11:54:12.953 に答える