[rabbitmq-discuss] Shovel plugin: queue.declare appears to do nothing

Wed Aug 31 12:20:23 BST 2011

Hi,

When I use the following configuration file:

[
    {mnesia, [{dump_log_write_threshold, 100}]},
    {rabbit, [{vm_memory_high_watermark, 0.4}]},
    {rabbitmq_shovel, [
        {shovels, [ 
                {app_to_italy_shovel, [
                    {sources, [
                        {brokers, ["amqp://"]},
                        {declarations, [
                            {'queue.declare', [{queue, <<"italy_out">>, durable}]},
                            {'exchange.declare', [
                                {exchange, <<"out">>},
                                {type, <<"topic">>},
                                durable
                            ]},
                            {'queue.bind', [
                                {exchange, <<"out">>},
                                {queue, <<"italy_out">>},
                                {routing_key, <<"italy.#">>}
                            ]}
                        ]}
                    ]},
                    {destinations, [
                        {broker, "amqp://guest:guest@italy.company.com"}
                    ]},
                    {queue, <<"italy_out">>},
                    {publish_fields, [{exchange, <<"in">>}]}
                ]}        

        ]}
    ]}
].

I get the following result when running rabbit_shovel_status:status().

(rabbit at MYCOMP)1> rabbit_shovel_status:status().
[{irims_to_italy_shovel,
     {terminated,
         {{shutdown,
              {server_initiated_close,404,
                  <<"NOT_FOUND - no queue 'italy_out' in vhost '/'">>}},
          {gen_server,call,
              [<0.584.0>,
               {call,
                   {'queue.bind',0,<<"italy_out">>,<<"out">>,<<"italy.#">>,
                       false,[]},
                   none},
               infinity]}}},
     {{2011,8,31},{12,27,38}}}]

The result is exactly the same if I remove the queue.declare from declarations, which to  indicates that the queue.declare statement doesn't do anything. Worth mentioning is that it works well with the Most-Recently-Declared-Queue approach (remove "italy_out"):

(rabbit at GOT044)2> rabbit_shovel_status:status().
[{irims_to_italy_shovel,
     {running,
         {source,
             {amqp_params_direct,<<"guest">>,<<"/">>,rabbit at GOT044,none,
                 []}},
         {destination,
             {amqp_params_network,<<"guest">>,<<"guest">>,<<"/">>,
                 "got032",5672,0,0,0,none,
                 [#Fun<amqp_auth_mechanisms.plain.3>,
                  #Fun<amqp_auth_mechanisms.amqplain.3>],
                 []}}},
     {{2011,8,31},{13,15,3}}}]

However, I'd like to be able to name my queues in advance.

Using RabbitMQ 2.5.1 on Windows 7, Erlang OTP R14B03 (erl5.8.4).

Grateful for any input.
Max