romp
Romp is a lightweight Streaming Text Oriented Messaging Protocol client for Ruby. Stomp is a text-based wire format that lets clients communicate through a variety Stomp message brokers, providing interoperable, cross-language messaging.
Getting started
Install a stomp broker and start it up. Both StompServer and CoilMQ don’t seem to handle ‘ack:auto` correctly, so I’ve been testing with HornetQ.
git clone git://github.com/jmesnil/hornetq-stomp.git
cd hornetq-stomp
ant server
Usage
require 'romp'
r1 = Romp.new("localhost", 61613)
r2 = Romp.new("localhost", 61613)
r1.with_connection(:login => "foo", :password => "password") do
r1.send("foo", :destination => "/queue/a")
r1.send("bar", :destination => "/queue/a")
end
r2.with_connection(:login => "bar", :password => "secret") do
r2.subscribe(:destination => "/queue/a")
puts r2.receive.body # => foo
puts r2.receive.body # => bar
end
Copyright
Copyright © 2010 Justin Balthrop. See LICENSE for details.