[rabbitmq-discuss] Shovel breaking: Was there a change in shovel config from 3.0.4 to 3.1.5?

Thu Sep 5 17:32:15 BST 2013

Hmm. The config you posted looks OK to me (at least I was able to load 
it). What error message are you seeing?

The only change to the shovel in 3.1.x is support for failover in 
clusters - in older versions if you started multiple shovels with the 
same name on different nodes they would run simultaneously, now only one 
runs with another starting if the first one's node fails.

Cheers, Simon

On 05/09/2013 5:10PM, Jason McIntosh wrote:
> I have the exact same configuration of shovel that i used in 3.0.4 and
> tried to use it in 3.1.5 and I get syntax errors now.  Did something
> change in 3.1.5?  Below is the config file I'm using that fails (this
> same config file works perfectly fine on a 3.0.4 server).  I've looked
> at this and looked at this, and can't see anything wrong or that doesn't
> match the documentation.  As soon as I remove the shovel configuration
> section, the server starts fine.  I get a crash message saying an
> invalid configuration (4) before the .
> Anyone see anything wrong?
> Thanks!
> Jason
>
> [
>
>   {rabbit, [ {vm_memory_high_watermark, 0.6}, {hipe_compile, false} ]},
>   {rabbitmq_shovel,[{shovels, [  { service.unknown.errors, [
>                    {sources,      [{broker,
> "amqp://username:password@/vhost"}] }
>                  , {destinations, [{broker,
> "amqp://username:password@destinationserver/vhost"}] }
>                  , {queue, <<"service.unknown.errors">>}
>                  , {prefetch_count, 15}
>                  , {publish_properties, [
>                          {delivery_mode, 2}
>                          , {headers,
> [{<<"source">>,longstr,<<"originatinghost">>}] }
>                          ]}
>                  , {reconnect_delay, 5}
>          ] },
>          { prod.service.activity, [
>                    {sources,      [{broker,
> "amqp://username:password@/vhost"}] }
>                  , {destinations, [{broker,
> "amqp://username:password@destinationserver/vhost"}] }
>                  , {queue, <<"prod.service.activity">>}
>                  , {prefetch_count, 15}
>                  , {publish_properties, [
>                          {delivery_mode, 2}
>                          , {headers,
> [{<<"source">>,longstr,<<"originatinghost">>}] }
>                          ]}
>                  , {reconnect_delay, 5}
>          ] },
>          { prod.service.activity.errors, [
>                    {sources,      [{broker,
> "amqp://username:password@/vhost"}] }
>                  , {destinations, [{broker,
> "amqp://username:password@destinationserver/vhost"}] }
>                  , {queue, <<"prod.service.activity.errors">>}
>                  , {prefetch_count, 15}
>                  , {publish_properties, [
>                          {delivery_mode, 2}
>                          , {headers,
> [{<<"source">>,longstr,<<"originatinghost">>}] }
>                          ]}
>                  , {reconnect_delay, 5}
>          ] },
>          { monitoring.service.activity, [
>                    {sources,      [{broker,
> "amqp://username:password@/vhost"}] }
>                  , {destinations, [{broker,
> "amqp://username:password@destinationserver/vhost"}] }
>                  , {queue, <<"monitoring.service.activity">>}
>                  , {prefetch_count, 15}
>                  , {publish_properties, [
>                          {delivery_mode, 2}
>                          , {headers,
> [{<<"source">>,longstr,<<"originatinghost">>}] }
>                          ]}
>                  , {reconnect_delay, 5}
>          ] },
>          { monitoring.service.activity.errors, [
>                    {sources,      [{broker,
> "amqp://username:password@/vhost"}] }
>                  , {destinations, [{broker,
> "amqp://username:password@destinationserver/vhost"}] }
>                  , {queue, <<"monitoring.service.activity.errors">>}
>                  , {prefetch_count, 15}
>                  , {publish_properties, [
>                          {delivery_mode, 2}
>                          , {headers,
> [{<<"source">>,longstr,<<"originatinghost">>}] }
>                          ]}
>                  , {reconnect_delay, 5}
>          ] }]}]}
> ].
>
>
>
> --
> Jason McIntosh
> http://mcintosh.poetshome.com/blog/
> 573-424-7612
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>

-- 
Simon MacMullen
RabbitMQ, Pivotal