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