Contents

# Allow examples to be run in-place without requiring a gem install
$LOAD_PATH.unshift File.dirname(__FILE__) + '/../../lib'

require 'rubygems'
require 'modern_times'
require 'yaml'
require 'reverse_echo_worker'

if ARGV.size < 1
  $stderr.puts "Usage: {$0} <reverse-echo-string> [<timeout>] [<sleep-time>] [<simultaneous-count>]"
  exit 1
end

$echo_string =  ARGV[0]
$timeout     = (ARGV[1] || 4).to_f
$sleep_time  = (ARGV[2] || 2).to_i
$sim_count   = (ARGV[3] || 1).to_i

config = YAML.load_file('hornetq.yml')
ModernTimes::HornetQ::Client.init(config['client'])
$requestor = ModernTimes::HornetQRequestor::Requestor.new(ReverseEchoWorker.address_name, :marshal => :string)

def make_request(ident='')
  puts "#{ident}Making request at #{Time.now.to_f}"
  handle = $requestor.request("#{ident}#{$echo_string}", $timeout)
  # Here's where we'd go off and do other work
  sleep $sleep_time
  puts "#{ident}Finished sleeping at #{Time.now.to_f}"
  response = handle.read_response
  puts "#{ident}Received at #{Time.now.to_f}: #{response}"
rescue Exception => e
  puts "#{ident}Exception: #{e.message}"
end

if $sim_count == 1
  make_request
else
  threads = []
  (1..$sim_count).each do |i|
    threads << Thread.new(i) do |i|
      make_request("Thread ##{i}: ")
    end
  end
  threads.each {|t| t.join}
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
modern_times-0.1.2	examples/requestor/request.rb