[rabbitmq-discuss] Basic help with Shovel

ristretto.rb ristretto.rb at gmail.com
Wed Apr 20 06:25:47 BST 2011


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:

      [{sources,  [{brokers,
       {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().
- no queue 'outgoing' in vhost '/'">>}},



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.

          [{exchange, <<"test_exchange">>},
           {queue,    <<>>}]}

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


More information about the rabbitmq-discuss mailing list