Example of using RabbitMQ's Federation Plugin with Ruby-AMQP
Ruby Shell
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
node1
node2
.gitignore
Gemfile
Gemfile.lock
README.md
cleanup.sh
consumer_from_node1.rb
consumer_from_node2.rb
create-federations.sh
producer_to_node1.rb
producer_to_node2.rb
start-node1.sh
start-node2.sh

README.md

ruby-amqp-federation-example

Example of using RabbitMQ's Federation Plugin with Ruby-AMQP

Step 1 - Start RabbitMQ Nodes (in 2 separate terminals)

bash start-node1.sh
bash start-node2.sh
  • Node 1 runs on port: 25672, management interface: 55555
  • Node 2 runs on port: 35672, management interface: 55556

Step 2 - Prepare environment and create federations

bundle install
bash cleanup.sh
bash create-federations.sh

Step 3 - Start the Consumer/Producer

From separate terminals, run:

ruby consumer_from_node1.rb
ruby consumer_from_node2.rb

Then try producing messages to either node, both will receive the messages:

ruby producer_to_node2.rb