class RPCBench::Stomp::Client

Constants

TEMP_QNAME

Public Class Methods

new(opts) click to toggle source
# File lib/rpc_bench/driver_stomp.rb, line 9
def initialize opts
  @opts = opts
end

Public Instance Methods

send_request(data, count) click to toggle source
# File lib/rpc_bench/driver_stomp.rb, line 13
def send_request data, count
  results = []

  conn = ::Stomp::Connection.open('guest', 'guest', @opts[:host], @opts[:port])
  (1..count).each do |x|
    conn.publish(RPCBench::Stomp::QNAME, data.to_s, {
      'reply-to' => TEMP_QNAME
    })
  end
  (1..count).each do |_|
    results << conn.receive.body.slice(/[0-9]*/).to_i
  end
  conn.disconnect

  results
end