= RabbitMQ și Minion == 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.