This package provides reliable messaging and persistent queues for building asynchronous applications in Ruby.

This release provides the following features:

• Simple API.

• Transction processing.

• Disk-based and MySQL message stores.

• Best effort, repeated, unique, replaceable and once-only delivery semantics.

• Priority queues, message expiration, message activation, dead-letter queue.

• Message selectors.

• Local and remote queue managers using DRb.

The latest version of Reliable Messaging can be found at

• rubyforge.org/projects/reliable-msg/

You can download the sources directly, or install the GEM package (recommended) with

gem install reliable-msg

To create the configuration file and queues for use with the disk-based message store

queues install disk [<path>]

The optional path argument specifies the directory in which queue index and messages are store. The default directory is queues.

To create the configuration file and queues for use with the MySQL message store

queues install mysql <host> <user> <password> <database>
       [--port <port>] [--socket <socket>] [--prefix <prefix>]

You must have MySQL libraries installed in order to use this message store, either native MySQL libraries or the Rails pure-Ruby adapter. It uses the supplied connection properties and creates tables in your database using the specified prefix. The default prefix is reliable_msg_.

For example

queues install mysql localhost my-db user secret

The installation process creates a configuration file (queues.cfg) located in the same directory as the library. You can specify a different location for the configuration file using the option -c of --config.

When you use the queue manager, it looks for a specified configuration file, or if no configuration file is specified it looks for the queues.cfg file, first in the local directory and then in the installation directory. If no file exists, it will create a default one to use the disk-based message store.

Reliable messaging requires a UUID generator that is able to create universally unique identifiers. The UUID generator uses the uuid.state file to hold a unique machine identifier and a rolling sequence number.

On the first usage, a uuid.state file is created in the installation directory. An existing state file will be used if one exists in the local directory or the installation directory.

The unique machine identifier is obtained from one of the network card’s MAC address on your machine, using either the ipconfig or ifconfig commands. If no MAC address can be found, or you want to pick a specific MAC address, create a uuid.state file manually.

Start the queue manager as a standalone server

queues manager start

Use the queue API in your application

require 'rubygems'  # not needed for ruby 1.9.x
require 'reliable-msg'

obj = 'test message'
queue = ReliableMsg::Queue.new 'my-queue'
queue.put obj
msg = queue.get

puts "original text:   #{obj}"
puts "queue returned:  #{msg.object}"

Stop the queue manager

queues manager stop

This package is licensed under the MIT license and/or the Creative Commons Attribution-ShareAlike.