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
-
Install and start RabbitMQ (see below)
-
Install JRuby RabbitMQ Client: jruby -S gem install rabbitmq-jruby-client
Example Usage
gem ‘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 rabbitmq-server
To run RabbitMQ
-
sudo rabbitmq-server