带交替交换的RabbitMQ铲配置

Question

我正在尝试使用声明列表为RabbitMQ配置铲子插件。我已将远程exchange配置为在创建时具有备用exchange。

我的问题是，我无法让slot的配置文件包含这个参数，所以RabbitMQ在启动时崩溃。

这是我的配置的样子：

[
    {mnesia, [{dump_log_write_threshold, 100}]},
    {rabbit, [{vm_memory_high_watermark, 0.4}]},
    {rabbitmq_shovel,
        [{shovels,
            [{call_stats_shovel,
                [{sources, [{broker, "amqp://guest:guest@localhost:5672/test"},
                    {declarations,
                        [{'queue.declare', [{queue, <<"incoming">>}, durable]},
                        {'exchange.declare',[{exchange, <<"my-exchange-topic">>},{type, <<"topic">>},durable]},
                        {'queue.bind',[{exchange, <<"my-exchange-topic">>},{queue, <<"incoming">>}]}
                ]}]},
                {destinations, [{broker, "amqp://guest:guest@172.16.3.162:5672/blah"},
                    {declarations,
                    [
                        {'queue.declare',[{queue, <<"billing">>},durable]},
                        {'exchange.declare',[{exchange, <<"my-exchange-topic">>},{type, <<"topic">>},{alternate_exchange, <<"alt">>}, durable]},
                        {'queue.bind',[{exchange, <<"my-exchange-topic">>},{queue, <<"billing">>},{routing_key, <<"physical">>}]}
                    ]}
                ]},
                {queue, <<"incoming">>},
                {ack_mode, no_ack},
                {publish_properties, [{delivery_mode, 2}]},
                {reconnect_delay, 5}
                ]}
            ]
        }]
    }
].

问题出在名为my-exchange-topic的目的交换上。如果我去掉声明部分，那么配置文件就工作了。

这是错误：

=INFO REPORT==== 31-Jul-2012：：12：15：25 === 应用程序： rabbitmq_shovel 退出： {{invalid_shovel_configuration，call_stats_shovel， {invalid_parameter_value，destinations， {unknown_fields，'exchange.declare'， [alternate_exchange]}}}， {rabbit_shovel，start，[normal，[]]}} 类型： permanent

如果我离开声明的alternate_exchange部分，我在RabbitMQ Web管理中得到这个错误：

｛｛关机，｛server_initiated_close，406，

Answer 1

为了澄清上面的评论，如果是exchange e2Exchange铲，配置将是：

{'exchange.declare',[{exchange, <<"my-exchange-topic">>},{type, <<"topic">>}, durable, {arguments, [{<<"alternate-exchange">>, longstr, <<"name-of-your-alternate-exchange">>}]}  ]},

Answer 2

对于任何想了解如何配置需要额外参数的交换和队列的人，您可以这样做:

{'exchange.declare',[{exchange, <<"my-exchange-topic">>},{type, <<"topic">>}, durable, {arguments, [{<<"alternate-exchange">>, longstr, <<"alternate-exchange">>}]}  ]},

您可以对队列做类似的事情：

{'queue.declare',[{queue, <<"my-queue">>},durable, {arguments, [{<<"x-dead-letter-exchange">>, longstr, <<"dead-letter-queue">>}]}]}