[rabbitmq-discuss] shovel plugin installation problem

Wed Aug 31 13:19:12 BST 2011

Hello list

I'm trying install the shovel plugin. Rabbit 2.5.1 installed from rpm 
package and is running fine on centos machine.
I have downloaded amqp_client-2.5.1.ez and rabbitmq_shovel-2.5.1.ez  to 
/usr/lib/rabbitmq/lib/rabbitmq_server-2.5.1/plugins

looks like both plugins are running:
(rabbit at node1)2>  rabbit:status().
[{pid,32668},
  {running_applications,[{rabbitmq_shovel,"Data Shovel for RabbitMQ",
                                          "2.5.1"},
                         {amqp_client,"RabbitMQ AMQP Client","2.5.1"},
                         {rabbit,"RabbitMQ","2.5.1"},
                         {os_mon,"CPO  CXC 138 46","2.2.5"},
                         {sasl,"SASL  CXC 138 11","2.1.9.3"},
                         {mnesia,"MNESIA  CXC 138 12","4.4.17"},
                         {stdlib,"ERTS  CXC 138 10","1.17.3"},
                         {kernel,"ERTS  CXC 138 10","2.14.3"}]},
  {os,{unix,linux}},
  {erlang_version,"Erlang R14B02 (erts-5.8.3) [source] [64-bit] 
[smp:2:2] [rq:2] [async-threads:30] [kernel-poll:true]\n"},
  {memory,[{total,24796104},
           {processes,9976400},
           {processes_used,9965192},
           {system,14819704},
           {atom,1118785},
           {atom_used,1112290},
           {binary,7720},
           {code,11154640},
           {ets,769080}]}]

however, rabbit_shovel_status does not return anything:
(rabbit at ndb-in-blr-1-01a)1>  rabbit_shovel_status:status().
[]

here is my rabbitmq.config:
[
     {mnesia, [{dump_log_write_threshold, 100}
              ]},
     {rabbit, [{vm_memory_high_watermark, 0.4}
              ]},
     {rabbit_shovel,
        [{shovels,
          [{sample_shovel,
            [{sources, [{broker, "amqp://user1:pass@node1:5675/vhost1"},
                             {declarations,
                                ['queue.declare',
                                 {'queue.bind',
                                     [{exchange, <<"router">>},
                                      {queue, <<"msgs">>}]}
                                ]}]},
             {destinations, [{broker, 
"amqp://user2:pass2@node2:5675/vhost2"},
                             {declarations,
                                 [{'exchange.declare',
                                        [{exchange, <<"router">>},
                                         {type, <<"direct">>},
                                         durable]}
                                ]}]},
             {queue, <<"msgs">>},
             {prefetch_count, 10},
             {auto_ack, false},
             {tx_size, 0},
             {publish_properties, [{delivery_mode, 2}]},
             {publish_fields, [{exchange, <<"router">>}]},
             {reconnect_delay, 5}
            ]}
           ]
         }]
      }
].