A small examples showing a working queue federation

Minimum Viable Federation

# Minimum Viable Federation
#Upstream servers are the servers towards messages are originally published
#Downstream servers are where the messages get forwarded to

# 1. Two clusters
DOWNSTREAM_URL="amqps://tynqsojc:PASSWD@test-server-1.rmq.cloudamqp.com/tynqsojc" 
UPSTREAM_URL="amqps://prksmzye:PASSWD@test-server-2.rmq.cloudamqp.com/prksmzye"
VHOST=tynqsojc
HTTPS_DOWNSTREAM="https://tynqsojc:PASSWD@test-server-1.rmq.cloudamqp.com"

# 2. Queue
# Create queue on upstream and load it with 100000 messages
rabbitmq-perf-test-2.9.1/bin/runjava com.rabbitmq.perf.PerfTest -h $UPSTREAM_URL -ad false  -f persistent -x 1 -y 0 -u myfedqueue -pmessages 100000

# 3. Create policy on downstream
curl -i -v -X PUT -H 'Content-Type: application/json' $HTTPS_DOWNSTREAM/api/policies/$VHOST/fedit/ -d '{"pattern":"myfedqueue", "definition": {"federation-upstream-set":"all"}, "priority":0, "apply-to": "queues"}'

# 4. Create federation-upstream on downstream
curl -i -XPUT -H "content-type:application/json" -d'{"value":{"uri":"'$UPSTREAM_URL'"}}' $HTTPS_DOWNSTREAM/api/parameters/federation-upstream/$VHOST/upstream

# 5. Create consumers on downstream (without consumers, no links!):
rabbitmq-perf-test-2.9.1/bin/runjava com.rabbitmq.perf.PerfTest -h $DOWNSTREAM_URL -ad false  -f persistent -x 0 -y 1 -u myfedqueue