Skip to content


Subversion checkout URL

You can clone with
Download ZIP
Simple gem to wrap communication between services by RabbitMQ
Branch: master

Fetching latest commit…

Cannot retrieve the latest commit at this time

Failed to load latest commit information.



Add this line to your application's Gemfile:

gem 'run_rabbit_run'

And then execute:

$ bundle

Or install it yourself as:

$ gem install run_rabbit_run


Including the rake tasks

Require the rake tasks in your Rakefile

require "run_rabbit_run/tasks"

Rake tasks

RAKE_ENV=production bundle exec rake rrr:start

Starts the master process and it starts all worker processes for production environment (default is development).

bundle exec rake rrr:stop

Stops the master process. Master process sends QUIT signal to workers and waits for 5 seconds. If processes are still running the master kills them.

bundle exec rake rrr:reload

Master stops all workers and then starts the profile again.

bundle exec rake rrr:worker:add[worker_name]

Master runs new process for given worker.

bundle exec rake rrr:worker:remove[worker_name]

Master stops one worker process.


you need to create config/rrr.rb file to set your config variables

log "log/run_rabbit_run.log"
pid "tmp/pids/"

worker :worker1, 'workers/worker_name_1.rb', processes: 0
worker :worker2, 'workers/worker_name_2.rb', processes: 2
worker :worker3, 'workers/worker_name_3.rb', processes: 1
  • log sets path to log file
  • pid sets path to pid file
  • worker sets settings for worker. The first argument is the worker name. The second argument is the path to the worker ruby file. And you can pass options as a third parameter. The processes option sets the process count for worker, default is 1. If process count is 0 then no processes will be run, you can run the process by bundle exec rake rrr:worker:add[worker_name].

Another config file you need to create is configuration file for environment eg. config/rrr/development.rb or config/rrr/production.rb

run :worker1, :worker2

run points the workers which will be run for the environment. In this case it will run only worker1 and worker2 but exlude the worker3.

Creating worker

This is the "Hello world" worker. It creates test_queue, sends simple message to this queue, subscribes to the same queue and prints it into log file.

test_queue = channel.queue('test_queue', auto_delete: false)

publish(test_queue, {some: 'data'})

subscribe(test_queue) do | header, data | data.inspect

Sometimes we need to have workers which does something and shuts down. For example send some messages and end the process. It is possible if you set processes to 0 for the worker in config file. If the processes count is set to number bigger than 0 then master will run the process again after it finishes.


# ... some code
worker :worker1, 'workers/worker_name_1.rb', processes: 0
# ... some code


test_queue = channel.queue('test_queue', auto_delete: false)

publish(test_queue, {some: 'data'})


  1. Fork it
  2. Create your feature branch (git checkout -b my-new-feature)
  3. Commit your changes (git commit -am 'Added some feature')
  4. Push to the branch (git push origin my-new-feature)
  5. Create new Pull Request
Something went wrong with that request. Please try again.