stompcat.rb

#! /usr/bin/env ruby

# Run me like this:
#
#   ./stompcat.rb mq.example.com /topic/foo.bar.baz.quux
#

require 'rubygems'
require 'smqueue'
require 'json'

configuration = {
  :host => ARGV[0],
  :name => ARGV[1],
  :adapter => :StompAdapter
}

source = SMQueue(configuration)
source.get do |m|
  payload = case m.headers["content-type"]
  when /^application\/json\s/
    JSON[m.body]
  else
    m.body
  end
  puts ">>> #{payload}"
end