[rabbitmq-discuss] Shovel breaking: Was there a change in shovel config from 3.0.4 to 3.1.5?
Simon MacMullen
simon at rabbitmq.com
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
More information about the rabbitmq-discuss
mailing list