playing around with the siberite ruby client

siberite_demo.rb

require 'siberite-client'

prefix = ARGV[0]

Thread.new do
  queue = Siberite::Client.new('localhost:22133', 'localhost:22144')
  i = 0
  loop do
    i += 1
    item = "#{prefix}#{i}"
    queue.set('test', item)
    puts "published: #{item}"
  end
end

queue2 = Siberite::Client.new('localhost:22133', 'localhost:22144')
loop do
  item = queue2.get('test')
  puts "received:  #{item}" if item
end