Simpel Ruby STOMP Client

README

This Gist is really part of an article Mark Eschbach wrote at http://meschbach.com/kb/simple-ruby-stomp-client.html.

consumer.rb

#!/usr/local/bin/ruby18

require ‘gem’
require ‘stomp’

port = 61613
client = Stomp::Client.new( “password”, “user”,  “broker.host.name”, port )
client.subscribe(‘/queue/stdin’) {
  | message |
  if( message.headers[‘type’] == ‘terminate’ )
    client.close
  else
    puts message.body
  end
}
client.join

producer.rb

#!/usr/local/bin/ruby18

require ‘gem’
require ‘stomp’
port = 61613
client = Stomp::Client.new( “password”, “user”,  “broker.host.name”, port )
stdin.each { |line|
  client.send( “/queue/stdin”, line, { ‘amq-msg-type’=>’text’,’type’=>’content’})
}
client.send(“/queue/stdin”, “”, {‘amq-msg-type’=>’text’, ‘type’=>’terminate’})
client.close