SystemStack Redis and RabbitMQ Cluster

require './cluster'

if ARGV.length != 2 startup_nodes = [ {:host => "127.0.0.1", :port => 6379}, {:host => "127.0.0.1", :port => 6380} ] else startup_nodes = [ {:host => ARGV[0], :port => ARGV[1].to_i} ] end

rc = RedisCluster.new(startup_nodes,32,:timeout => 0.1)

last = false

while not last begin last = rc.get("last") last = 0 if !last rescue => e puts "error #{e.to_s}" sleep 1 end end

((last.to_i+1)..1000000000).each{|x| begin rc.set("foo#{x}",x) puts rc.get("foo#{x}") rc.set("last",x) rescue => e puts "error #{e.to_s}" end sleep 0.1 }