Instalarea
apt-get install rabbitmq-server rubygems gem install minion
Exemple de cod
Programul ce trimite mesaje
#!/usr/bin/ruby
require 'rubygems'
require 'minion'
Minion.enqueue('make.sandwich', { 'for' => 'me', 'with' => 'bread' })
Programul care primește mesajele
#!/usr/bin/ruby require 'rubygems' require 'minion' Minion.job 'make.sandwich' do |args| p args end
Testarea
$ ./sender.rb
# Fri Apr 30 13:28:58 +0300 2010 :minion: send: make.sandwich:{"for":"me","with":"bread"}
$ ./receiver.rb
Fri Apr 30 13:29:27 +0300 2010 :minion: Starting minion
Fri Apr 30 13:29:27 +0300 2010 :minion: subscribing to make.sandwich
Fri Apr 30 13:29:27 +0300 2010 :minion: recv: make.sandwich:{"for":"me","with":"bread"}
{"for"=>"me", "with"=>"bread"}
Erori
Dacă serverul Rabbitmq nu lucrează, cel ce trimite mesajul primește eroare de tip Bunny::ServerDownError:
Connection refused - connect(2) (Bunny::ServerDownError)
Clientul ce prelucrează mesajele:
Could not connect to server localhost:5672 (AMQP::Error)
Așa că aveți grijă să prindeși erorile dacă țineți cont de ele.