class MQBench::STOMP
Public Class Methods
new(args)
click to toggle source
Calls superclass method
MQBench::Client::new
# File lib/mqbench/stomp.rb, line 5 def initialize(args) @port = 61613 @user = 'guest' @pass = 'guest' super(args) @broker = Stomp::Connection.open(@user, @pass, @host, @port) end
Public Instance Methods
recv_msg()
click to toggle source
# File lib/mqbench/stomp.rb, line 21 def recv_msg @broker.subscribe(QNAME, {:ack => 'client'}) cnt = 0 loop do @broker.receive cnt += 1 if cnt >= @count break end end end
send_msg()
click to toggle source
# File lib/mqbench/stomp.rb, line 15 def send_msg (1..@count).each do |x| @broker.publish(QNAME, 'a' * @size) end end