Shovel Example

shovel-example.erl

{rabbit_shovel, [
    {shovels, [
        {my_first_shovel, [
            {sources, [
                {brokers, ["amqp://user:pwd@host1/vhost"]},
                {declarations, [
                    {'exchange.declare', [{exchange, <<"source_exchange">>}, {type, <<"direct">>}, durable]}
                    {'queue.declare', [{queue, <<"source_queue">>}, durable]},
                    {'queue.bind', [{exchange, <<"source_exchange">>}, {queue, <<"source_queue">>}]}
                ]}
            ]},
            {destinations, [
                {broker, "amqp://user:pwd@host2/vhost"},
                {declarations, [
                    {'exchange.declare', [{exchange, <<"destination_exchange">>}, {type, <<"direct">>}, durable]}
                    {'queue.declare', [{queue, <<"destination_queue">>}, durable]},
                    {'queue.bind', [{exchange, <<"desintation_exchange">>}, {queue, <<"destination_queue">>}]}
                ]}
            ]}
        ]},
        {queue, <<"source_queue">>},
        {publish_fields, [
            {exchange, <<"destination_exchange">>}
        ]}
    ]}
]}