[rabbitmq-discuss] Basic help with Shovel

Wed Apr 20 06:25:47 BST 2011

Hello,

Rabbitmq is a very nice product.  Thanks to all the people that have
put in time to creating this excellent bit of software.

I am trying to get a simple example of rabbitmq-shovel working between
two rabbitmq brokers.  I have the shovel plugin installed
(rabbitmq-shovel-2.4.1.ez.)  I'm using the rabbit 2.4.0:

I have tried a number of config files. Here is a basic one:

[{rabbit_shovel,
  [{shovels,
    [{outgoing,
      [{sources,  [{brokers,
                          ["amqp://"]}
                       ]},
       {destinations, [{broker, "amqp://tortuga/"}
                       ]},
       {queue, <<"outgoing">>},
       {prefetch_count, 1},
       {auto_ack, false},
       {tx_size, 0},
       {publish_properties, [{delivery_mode, 2}]},
       {publish_fields, [{exchange, <<"test_exchange">>},
                        {routing_key, <<"from_shovel">>}]},
      {reconnect_delay, 5}
      ]}
     ]
   }]
}].

My local system is the source, and my server named tortuga is the destination.

When I start the server, I get no errors.  But, when I look at
rabbit_shovel_status:status(), I see that the 'outgoing' exchange is
not found.  Should Shovel be creating that?

> rabbit_shovel_status:status().
[{outgoing,{terminated,{{shutdown,{server_initiated_close,404,
                                                          <<"NOT_FOUND
- no queue 'outgoing' in vhost '/'">>}},
                        {gen_server,call,
                                    [<0.12894.0>,

{subscribe,{'basic.consume',0,<<"outgoing">>,<<>>,false,

false,false,false,[]},
                                                <0.12886.0>},
                                     infinity]}}},
           {{2011,4,19},{22,12,0}}}]

In addition to all this, it seem that Shovel might be creating a bunch
of unnamed queues

$ sudo rabbitmqctl list_queues
[sudo] password for gbc:
Listing queues ...
amq.gen-Mi/SRrrk8QayvJsAGHgU3A==	0
amq.gen-tmkeQdFucANNYBE+Cvv2VQ==	0
amq.gen-iNur60R7wa1LOCMa6R6Klw==	0
amq.gen-AKxkcLiF1zh9EP6ArECZ3g==	0
amq.gen-htu38N+C5w2gCiTMdU3bug==	0
amq.gen-0vYlOHEJc0YjjBMZGecRng==	0
amq.gen-8n2ik3Z2+K/2D6SGS1dFjQ==	0
amq.gen-9Iys32AxkmLb6/9QW1jV3Q==	0
amq.gen-COSLe9fteqxWxcPGRm+1EQ==	0
amq.gen-fwJtLeLJQUqHeQP5fQzjsw==	0
amq.gen-P8c2DgxawkRAIWzP/8GeKw==	0
amq.gen-OxwGmt3k+3vDrt6Mhl1Emw==	0
amq.gen-oCLpwM/nNVmCXT1rr/pJ6A==	0
amq.gen-+aEtMLnGXrcTCs+WHVeStA==	0
amq.gen-vOzzeILG+M7iynDRmyypaQ==	0
amq.gen-q8CYOBNl8JXketYJq6Je5Q==	0
amq.gen-9cQqY8oqkPYj+cSS9fuOQw==	0
:
:

Thank you

Finally, if I put a declaration in to the sources or destinations it
makes no difference.  I thought, perhaps, that these lines would
create the exchange for me.

:
{declarations,
     ['queue.declare',
         {'queue.bind',
          [{exchange, <<"test_exchange">>},
           {queue,    <<>>}]}
      ]}
:

Do I need to pre-create the exchanges and queues?

Thanks