RabbitMQ JRuby Client
rabbitmq-jruby-client allows you to use RabbitMQ Client from JRuby using the official Java RabbitMQ client from Rabbit Technologies See more at www.rabbitmq.com
Getting Started
-
Make sure you can install RubyGem from GitHub (you only have to do this once): jruby -S gem sources -a gems.github.com
-
Install and start RabbitMQ (see below)
-
Install JRuby RabbitMQ Client: jruby -S gem install jerryluk-rabbitmq-jruby-client
Example Usage
gem ‘jerryluk-rabbitmq-jruby-client’ require ‘rabbitmq_client’
# Initializes the new client and connect to the server client = RabbitMQClient.new
# Initializes a new queue queue = client.queue(‘queue_name’)
# Initializes a new exchange exchange = client.exchange(‘exchange_name’)
# Connects queue with the exchange queue.bind(exchange)
# Publish a message to the queue queue.publish(‘message body’)
# Retrieve a message from the queue message = queue.retrieve
# Subscribe to a queue with callback. The callback will be run in a new thread for each new message. queue.subscribe do |message|
# do something with message
end
# Subscribe to a queue in a loop. No new thread will be created. queue.loop_subscribe do |message|
# do something with message
end
Installing RabbitMQ on OS X
-
Install MacPorts
-
sudo port install erlang
-
wget www.rabbitmq.com/releases/rabbitmq-server/v1.5.3/rabbitmq-server-generic-unix-1.5.3.tar.gz
-
tar zxvf rabbitmq-server-1.5.3.tar.gz
-
sudo mv rabbitmq_server-1.5.3 /opt/local/lib/erlang/lib
To run RabbitMQ
-
sudo /opt/local/lib/erlang/lib/rabbitmq_server-1.5.3/sbin/rabbitmq-server