Contents

require 'rubygems'
require 'ffi-rzmq'

if ARGV.length != 3
	puts "usage: remote_thr <connect-to> <message-size> <message-count>"
	Process.exit
end
    
connect_to = ARGV[0]
message_size = ARGV[1].to_i
message_count = ARGV[2].to_i

ctx = ZMQ::Context.new
s = ZMQ::Socket.new ctx.pointer, ZMQ::PUB

s.connect connect_to

contents = "#{'0'*message_size}"

i = 0
while i < message_count
  msg = ZMQ::Message.new contents
	s.send msg
	i += 1
end

sleep 10

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
ffi-rzmq-0.8.2	examples/remote_throughput.rb
ffi-rzmq-0.8.0	examples/remote_throughput.rb
ffi-rzmq-0.7.2	examples/remote_throughput.rb
ffi-rzmq-0.7.1	examples/remote_throughput.rb
ffi-rzmq-0.7.0	examples/remote_throughput.rb
ffi-rzmq-0.6.0	examples/remote_throughput.rb